Какой блокирующий объект использовать?

Question

Мне нужен блокирующий объект для запуска некоторых событий. A (один) Потребителю следует дождаться появления триггера. Затем он делает кое-что. Затем он снова ждет спусковой крючок. Триггеры активируются несколькими различными потоками (Производители). Но производители не производят никаких данных. Семантический смысл такого триггера: «Потребитель должен что-то сделать» (например, пересчитать некоторые значения, поскольку базовые данные изменились). Это означает, что даже если триггер активирован несколько раз, он должен появиться для Потребителя как один триггер.

Я думал об использовании CountDownLatch или ArrayBlockingQueue, но они не подходят.

Это триггер конструкт Я хотел бы использовать:

public class Trigger{ 
    private final MagicBlockingObject blockingLatch; 

    public void trigger(){ 
    //activate the blockingLatch, so that a call to waitForTrigger() returns 
    } 

    public void waitForTrigger(){ 
    //read from the blockingLatch. This should block until trigger() is called. 
    } 
} 

Любые идеи о том, что использовать для MagicBlockingObject?

Answer 1

Вы могли бы решить эту проблему с ArrayBlockingQueue емкостью одного:

public class Trigger{ 
    private final ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(1); 

    public void trigger(){ 
    queue.offer("foo"); 
    } 

    public void waitForTrigger(){ 
    queue.take(); 
    } 
} 

Answer 2

Что такое проблема с простым решением, как это:

public class Trigger { 
    private final Object blockingLatch = new Object(); 

    public void trigger() { 
     //activate the blockingLatch, so that a call to waitForTrigger() returns 
     synchronized(blockingLatch){ 
      blockingLatch.notify(); 
     } 
    } 

    public void waitForTrigger() throws InterruptedException { 
     //read from the blockingLatch. This should block until trigger() is called. 
     synchronized(blockingLatch){ 
      blockingLatch.wait(); 
     } 
    } 
} 

Потребитель будет вызывать waitForTrigger() и заблокируют до производителя не называется триггером(). Если потребитель не заблокирован, то вызывающий триггер производителя() не повлияет ни на что.

Answer 3

java.util.concurrent имеет много хороших утилит. wait и notify следует считать устаревшими.

Если я понимаю вашу проблему, то вы можете попробовать использовать Semaphore

public class Blocking { 
    private final Semaphore openTasks = new Semaphore(0); 
    public void addTask() { 
     // add 1 
     openTasks.release(); 
    } 
    public void takeAllTasks() throws InterruptedException { 
     int immediately = openTasks.drainPermits(); 
     if (immediately > 0) { 
      // there was a task, no need to wait 
      return; 
     } 
     // wait for task 
     openTasks.acquire(); 
     // ensure we leave this method without leaving permits 
     openTasks.drainPermits() 
    } 
} 

An unlimitted количества производителей могут добавить «разрешения» на семафор и ваш потребитель просто берет их всех или ждет, по крайней мере, один появится ,