14

私はたくさん検索しましたが、解決策が見つかりませんでした。私は次のようにJavaスレッドプールを使用します：

ExecutorService c = Executors.newFixedThreadPool(3);
for (int i = 0; i < 10; ++i) {
  c.execute(new MyTask(i));
}

このようにして、タスクは結果の順序で (キューのように) 実行されます。しかし、「次のタスクを選択する」戦略を変更する必要があります。したがって、各タスクに割り当てて優先度を指定し（スレッドの優先度ではありません）、これらの優先度に対応するタスクを実行します。そのため、エグゼキュータが別のタスクを終了すると、次のタスクを最大優先度のタスクとして選択します。一般的な問題について説明します。優先順位を考慮しない、より単純なアプローチがあるかもしれません。最初に追加されたタスクではなく、最後に追加されたタスクを次に実行するように選択します。大まかに言うと、FixedThreadPool は FIFO 戦略を使用します。たとえば、LIFO 戦略を使用できますか?

4

2 に答える 2

12

PriorityBlockingQueueを使用して、Queue を ThreadPoolExecutor に指定できます。

public class PriorityExecutor extends ThreadPoolExecutor {

    public PriorityExecutor(int corePoolSize, int maximumPoolSize,
            long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
    }
    //Utitlity method to create thread pool easily
    public static ExecutorService newFixedThreadPool(int nThreads) {
        return new PriorityExecutor(nThreads, nThreads, 0L,
                TimeUnit.MILLISECONDS, new PriorityBlockingQueue<Runnable>());
    }
    //Submit with New comparable task 
    public Future<?> submit(Runnable task, int priority) {
        return super.submit(new ComparableFutureTask(task, null, priority));
    }
    //execute with New comparable task 
    public void execute(Runnable command, int priority) {
        super.execute(new ComparableFutureTask(command, null, priority));
    }
}

ComparableFutureTaskPriority で比較するように定義します。

class ComparableFutureTask<T> extends FutureTask<T>
        implements
            Comparable<ComparableFutureTask<T>> {

    volatile int priority = 0;

    public ComparableFutureTask(Runnable runnable, T result, int priority) {
        super(runnable, result);
        this.priority = priority;
    }
    public ComparableFutureTask(Callable<T> callable, int priority) {
        super(callable);
        this.priority = priority;
    }
    @Override
    public int compareTo(ComparableFutureTask<T> o) {
        return Integer.valueOf(priority).compareTo(o.priority);
    }
  }
于 2012-10-04T07:52:31.230 に答える
7

ThreadPoolExecutor コンストラクターは BlockingQueue を受け入れます。queue を PriorityBlockingQueue として渡すことができます。順序を維持するためにカスタムコンパレータを渡す必要がある順序で、権限付与対象者を作成しません。

static BlockingQueue<Task> queue=new PriorityBlockingQueue<Task>(MAXPOOL,new TaskComparator());

static ThreadPoolExecutor threadpool = new ThreadPoolExecutor(30, MAXPOOL, 
        MAXPOOL, TimeUnit.SECONDS, (PriorityBlockingQueue) queue, new mThreadFactory());



class TaskComparator implements Comparator<Task>{
  public int compare(Task t1, Task t2){
    //write you own logic to compare two task.
  }
}
于 2012-10-04T08:05:25.210 に答える