Исполнитель и графикWithFixedDelay()

Question

Вот моя задача. У меня статическая очередь заданий в классе и статический метод, который добавляет задания в очередь. Имейте n количество потоков, опрошенных в очереди и выполняющих задание. Мне нужно провести опрос n потоков одновременно с интервалом. AKA, все 3 должны опросить каждые 5 секунд и искать работу.

У меня есть это:

public class Handler { 

    private static final Queue<Job> queue = new LinkedList<>(); 

    public static void initialize(int maxThreads) { // maxThreads == 3 

     ScheduledExecutorService executorService = 
      Executors.newScheduledThreadPool(maxThreads); 

     executorService.scheduleWithFixedDelay(new Runnable() { 
      @Override 
      public void run() { 
       Job job = null; 
       synchronized(queue) { 
        if(queue.size() > 0) { 
         job = queue.poll(); 
        } 
       } 
       if(job != null) { 
        Log.log("start job"); 
        doJob(job); 
        Log.log("end job"); 
       } 
      }  
     }, 15, 5, TimeUnit.SECONDS); 

    } 

} 

Я получаю этот вывод, когда я добавляю 4 задачи:

startjob 
endjob 
startjob 
endjob 
startjob 
endjob 
startjob 
endjob 

Очевидно, что эти нити выполняют, что задания последовательно, в то время как мне нужно их сделать 3 за раз. Что я делаю не так? Благодаря!

Answer 1

Из документации:

Если какое-либо выполнение этой задачи занимает больше времени, чем период, то последующее выполнение может начаться с опозданием, но не будет одновременно выполнять.

Итак, вы должны запланировать три независимые задачи, чтобы они запускались одновременно. Также обратите внимание, что запланированная служба-исполнитель представляет собой фиксированный пул потоков, который недостаточно гибкий для многих случаев использования. Хорошая идиома заключается в том, чтобы использовать запланированную службу только для отправки заданий регулярной службе исполнителя, которая может быть настроена как изменяемый пул потоков.

Answer 2

Вы используете ScheduledExecutorService с фиксированной задержкой, что значит, что ваши задания будут работать один за другим. Используйте фиксированный пул потоков и отправьте 3 потока за раз. Вот an explanation with examples

Answer 3

Если вы объявляете Job extends Runnable, то ваш код упрощает драматический:

Первых объявить Исполнитель где-то глобально доступный:

public static final ExecutorService executor = Executors.newFixedThreadPool(MAX_THREADS); 

Затем добавить работу, как это:

executor.submit(new Job()); 

Вы сделали.