У меня есть простой тест для ArrayBlockingQueue, как показано ниже:
public class TestQueue {
static class Producer implements Runnable {
private ArrayBlockingQueue<Integer> queue;
private int index;
public Producer(ArrayBlockingQueue<Integer> queue, int index) {
this.queue = queue;
this.index = index;
}
@Override
public void run() {
try {
queue.put(index);
System.out.println("producer: " + index);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
static class Consumer implements Runnable {
private ArrayBlockingQueue<Integer> queue;
public Consumer(ArrayBlockingQueue<Integer> queue) {
this.queue = queue;
}
@Override
public void run() {
try {
while(true) {
System.out.println("consumer: " + queue.take());
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<>(3);
for (int i = 0; i < 10; i++) {
Producer producer = new Producer(queue, i);
new Thread(producer).start();
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
Consumer consumer = new Consumer(queue);
new Thread(consumer).start();
}
}
Результат:
producer: 2
producer: 0
producer: 1
consumer: 0
producer: 4
producer: 6
consumer: 2
etc...
моя проблема в том, что я определил размер ArrayBlockingQueue как 3, в то время как производитель поместил 2, 0 и 1, всего 3 элемента в очередь, и очередь теперь заполнена, тогда потребитель потреблял 0, размер сейчас очередь должна быть 2, а потом, производитель поставил 4 в очередь, сейчас очередь должна быть заполнена, почему производитель все еще может поставить 6 в очередь, она должна быть заблокирована
System.out.println
не является потокобезопасным, поэтому это может выглядеть как значение было вставлено в полную очередь. - person Guy   schedule 12.08.2018System.out.println
? Это потокобезопасно. - person xingbin   schedule 12.08.2018