Как убедиться, что одна задача Runnable не работает одновременно на двух потоках

Question

. если у меня есть пул потоков из двух потоков, но хочу, чтобы каждый поток был посвящен одному типу задачи. то есть задача 1 может выполняться только в потоке 1 пула, задача 2 в потоке 2 пула. Я не хочу больше двух потоков, и я не хочу, чтобы две задачи (ы) запускались одновременно (по одному на каждый поток). Возможное??

Answer 1

Если вы хотите убедиться, что одна задача не выполняется в два раза, в то же время, использовать boolean, чтобы указать, что задача выполняется или нет:

(Java 8+)

volatile boolean task1Running = false; 

Runnable task1 =() -> { 
    if(task1Running) 
      return; //already running, exit 

    task1Running = true; 
    //handle task 
    task1Running = false; 
}; 

Теперь, когда вы пытаетесь выполнить его, пока он уже запущен, он выйдет. volatile должен гарантировать, что при изменении task1Running из темы, управляющей этой задачей, все остальные потоки (в частности, поток, выполняющий задачи) сразу увидят.

Answer 2

Нет, невозможно. Это преимущество использования пула потоков: пул будет выбирать, какой поток будет выполнять поставленную задачу. Обратите внимание, что даже если вы используете Executors#newFixedThreadPool(2), у вас будет пул потоков с двумя потоками, но это не гарантирует, что каждая задача выполняется в другом потоке.

Если вам нужно, чтобы ваши задачи выполнялись в разных конкретных потоках, вместо этого создайте свои собственные потоки. Если вы не хотите создавать потоки вручную, используйте 2 однопоточных исполнителей. Вы можете создать их, используя Executors#newSingleThreadExecutor (но это очень громоздко).

Answer 3

Хотя уже есть принятый ответ, вы должны использовать AtomicBoolean вместо volatile. Как в

AtomicBoolean task1RunningAB = new AtomicBoolean(false); 

Runnable task1 =() -> { 
    // compareAndSet(E, N) sets the value to N if current value matches E. 
    // Returns true if that was the case, so we must negate here 
    if (! task1RunningAB.compareAndSet(false, true)) 
     return; 
    try { 
     // your code 
    } finally { 
     task1RunningAB.set(false); 
    } 
};