Подтвердить что ты не робот

Указать выполнение задания задачи в Java

Я много искал, но не нашел никакого решения. Я использую пул потоков java таким образом:

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

Таким образом, задачи выполняются в последовательном порядке (как в очереди). Но мне нужно изменить стратегию "выбрать следующую задачу". Поэтому я хочу назначить каждой задаче указать приоритет (это не приоритет потока), а выполнение задач соответствует этим приоритетам. Поэтому, когда исполнитель закончил другую задачу, он выбирает следующую задачу как задачу с максимальным приоритетом. Он описывает общую проблему. Возможно, существует более простой подход, который не учитывает приоритеты. Он выбирает последнюю добавленную задачу как следующую для выполнения вместо первого добавления. Грубо говоря, FixedThreadPool использует стратегию FIFO. Могу ли я использовать, например, стратегию LIFO?

4b9b3361

ОТВЕТЫ

Ответ 1

Вы можете использовать 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));
    }
}

Определите ComparableFutureTask для сравнения по приоритету.

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);
    }
  }

Ответ 2

Конструктор ThreadPoolExecutor принимает BlockingQueue. Вы можете передать очередь как 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.
  }
}