用blockingQueue Java触发SheduledExecutor

Question

我目前正在研究java应用程序，它有一个场景，多个生产者将任务添加到队列中，每当队列不是空的时候，任务应该以预定义的速度执行。（使用多线程来保持执行速度）执行完可用的任务后，执行器必须等待队列中的任务再次可用。

我知道blockingQueue可以用来在这里触发part和ScheduledExecutorService以固定速率执行任务。但我找不到一种方法来联系这两者的能力，以满足我的需要。所以如果你能给我任何建议来实现这一点，我将非常感谢。

Answer 1

您需要任务队列能够被生产者线程和使用者线程访问。我已经编写了一个基本程序来演示这一点，但我将让您根据需要使用blockingqueueAPI和scheduledexecutor:

import java.util.concurrent.*;


public class ProducerConsumer {
    private static final BlockingQueue<Integer> taskQueue = new LinkedBlockingQueue<>();

    public static void main(String[] args) {
        ExecutorService consumers = Executors.newFixedThreadPool(3);
        consumers.submit(new Consumer());
        consumers.submit(new Consumer());
        consumers.submit(new Consumer());

        ExecutorService producers = Executors.newFixedThreadPool(2);
        producers.submit(new Producer(1));
        producers.submit(new Producer(2));
    }

    private static class Producer implements Runnable {
        private final int task;

        Producer(int task) {
            this.task = task;
        }

        @Override
        public void run() {
            System.out.println("Adding task: " + task);
            taskQueue.add(task); // put is better, since it will block if queue is full
        }
    }

    private static class Consumer implements Runnable {
        @Override
        public void run() {
            try {
                Integer task = taskQueue.take(); // block if there is no task available
                System.out.println("Executing task: " + task);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}