«Маршрутизация» задачи внутри ThreadPoolExecutor

Question

У меня есть класс, который реализует Runnable

public class MyRunnable implements Runnable { 
    private long RID = <SOME_LONG_ID_VALUE>; 
    public long getRID() { return this.RID; } 
    public void run { 
     System.out.println("HAI!"); 
    } 
} 

Есть ли способ «маршрут» задачи внутри ThreadPoolExecutor по RID полю (я имею в виду, если нить N 3 работает Runnable с RID = 1, то следующий вкус с RID = 1 должен выполняться нитью N 3 (если он жив)) Спасибо.

Answer 1

Ну, я не думаю, чтобы избежать состояния гонки (как упоминалось в ваших комментариях), это могло бы помочь в любом случае. Todo:

Если Thread N3 действительно больше не не существует, ThreadPoolExecutor не должны создавать новый поток с "ид" 3. Если поток занят, эта задача не должна быть выполнена до резьбы будет FRE

ThreadPoolExecutor Управление потоками для вас. Чтобы сделать это, невозможно сделать это с существующей библиотекой, вам, вероятно, придется создать свой собственный, чтобы сделать это. Если ваша логика и безопасность потоков зависит от RID, чем я довольно рекомендуем использовать Карту RID и ReentrantLock, somethign так:

ConcurrentHashMap<Long, ReentrantLock> map = new ConcurrentHashMap<Long, ReentrantLock>(); 

public synchornized ReentrantLock getLock(Long id){ 
    ReentrantLock lock = map.get(id); 
    if(lock!=null) 
     return lock; 
    else{ 
     map.put(id, new ReentrantLock()); 
} 

В вашем Runnable, вы можете получить lock к желаемым и синхронизировать соответственно.

IMHO, использующий thread-id пула потоков для синхронизации, является очень плохой идеей. Жизнь много раз может быть намного проще.

Answer 2

Как я понимаю, для каждого RID у вас есть контекст выполнения, и вы хотите последовательно выполнить все объекты MyRunnable в этом контексте.

Ваша ошибка в том, что вы пытаетесь связать этот контекст с потоком. Лучше представить этот контекст актером. Вы можете использовать широко известные актерские рамки, такие как Akka, но для вашей цели простой Actor implementation будет работать.

EDIT: Другая точка зрения: поскольку реализация Actor имеет единственный способ интерфейса execute, ее можно рассматривать как последовательный исполнитель, выполняющий поставленные задачи поочередно. И поскольку у него нет собственного потока, но он использует другого исполнителя, который делится между всеми Актерами, его можно назвать Вторичным Исполнителем.