Лучший способ получить объекты из BlockingQueue в параллельной программе?

голоса
4

Что является лучшим способом, чтобы получить объекты из BlockingQueue, в параллельной программе, не задев условия гонки? В настоящее время я делаю следующее, и я не уверен, что это лучший метод:

BlockingQueue<Violation> vQueue;
/* 
in the constructor I pass in a BlockingQueue object 
full of violations that need to be processed - cut out for brevity
*/

Violation v;
while ( ( v = vQueue.poll(500, TimeUnit.MILLISECONDS) ) != null ) {
    // do stuff with the violation
}

Я до сих пор не достиг состояния гонки ... но я не буду не слишком уверен, что если это действительно безопасно.

Задан 23/08/2008 в 05:03
источник пользователем
На других языках...                            


1 ответов

голоса
6

class Producer implements Runnable {
   private final BlockingQueue queue;
   Producer(BlockingQueue q) { queue = q; }
   public void run() {
     try {
       while (true) { queue.put(produce()); }
     } catch (InterruptedException ex) { ... handle ...}
   }
   Object produce() { ... }
 }

 class Consumer implements Runnable {
   private final BlockingQueue queue;
   Consumer(BlockingQueue q) { queue = q; }
   public void run() {
     try {
       while (true) { consume(queue.take()); }
     } catch (InterruptedException ex) { ... handle ...}
   }
   void consume(Object x) { ... }
 }

 class Setup {
   void main() {
     BlockingQueue q = new SomeQueueImplementation();
     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();
   }
 }

Этот пример взят из JDK 1.6 ДокументовBlockingQueue . Таким образом , вы можете видеть , что вы делаете это правильный путь. Вот цитата , которая говорит вам , что он должен работать:

непротиворечивость памяти эффекты: Как и в случае другими параллельных коллекций, действий в потоке до размещения объекта в BlockingQueue произойдет, до действий, следующих за доступ или удаление этого элемента из BlockingQueue в другом потоке.

Ответил 23/08/2008 d 06:39
источник пользователем

Cookies help us deliver our services. By using our services, you agree to our use of cookies. Learn more