今天我们通过实例来学习一下BlockingQueue的用法。梦想,可以天花乱坠,理想,是我们一步一个脚印踩出来的坎坷道路。
BlockingQueue的实例
官方文档上的对于BlockingQueue的说明:
A Queue that additionally supports operations that wait for the queue to become non-empty when retrieving an element, and wait for space to become available in the queue when storing an element.
如果BlockQueue是空的,从BlockingQueue取东西的操作将会被阻断进入等待状态,直到BlockingQueue进了东西才会被唤醒.同样,如果BlockingQueue是满的,任何试图往里存东西的操作也会被阻断进入等待状态,直到BlockingQueue里有空间才会被唤醒继续操作
一、BlockingQueue的简单使用
package com.linux.huhx.concurreny; import java.util.Random;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.TimeUnit; public class BlockingQueueTest {
public static void main(String[] args) {
BlockingQueue q = new LinkedBlockingDeque();
Producer p = new Producer(q);
Consumer c1 = new Consumer(q);
Consumer c2 = new Consumer(q);
new Thread(p).start();
new Thread(c1).start();
new Thread(c2).start();
} static class Producer implements Runnable {
private final BlockingQueue<String> queue;
Producer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
for (int i = 0; i < 4; i++) {
try {
queue.put("producer" + i);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
} static class Consumer implements Runnable {
private final BlockingQueue queue;
Consumer(BlockingQueue queue) {
this.queue = queue;
}
public void run() {
for (int i = 0; i < 2; i++) {
try {
TimeUnit.MILLISECONDS.sleep(new Random().nextInt(2000));
System.out.println(queue.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
运行的结果如下:使用put和take方法,打印的结果是固定的。它会阻塞。
producer0
producer1
producer2
producer3
二、ArrayBlockIngQueue的使用
package com.linux.thread.thread; import org.junit.Test; import java.util.concurrent.ArrayBlockingQueue; public class ArrayBlockQueueTest {
@Test
public void put() {
try {
ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(3);
queue.put("huhx");
queue.put("linux");
queue.put("ll");
System.out.println("size: " + queue.size());
System.out.println("begin: " + System.currentTimeMillis());
queue.put("tomhu"); // 阻塞
System.out.println("end: " + System.currentTimeMillis());
} catch (InterruptedException e) {
e.printStackTrace();
}
} @Test
public void get() {
try {
ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(3);
System.out.println("begin: " + System.currentTimeMillis());
System.out.println(queue.take()); // 阻塞
System.out.println("end: " + System.currentTimeMillis());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}