java多线程执行多队列

在Java中，多线程可以同时处理多个队列（Queue），这通常用于提高并发性能，例如从不同的数据源接收任务并独立地执行。下面是如何实现这个场景的一个基本步骤：

1. **创建队列**：你可以使用Java提供的`java.util.concurrent`包下的类，如`BlockingQueue`（同步队列）或`ArrayDeque`（数组双端队列）等，来存储待处理的任务。

import java.util.concurrent.BlockingQueue;
BlockingQueue<Runnable> queueA = new ArrayDeque<>();
BlockingQueue<Runnable> queueB = new ArrayDeque<>();

2. **创建线程池**：使用`ExecutorService`或`ThreadPoolExecutor`来管理多个工作线程，它们将从各自的队列中取任务执行。

ExecutorService executorA = Executors.newSingleThreadExecutor();
ExecutorService executorB = Executors.newSingleThreadExecutor();

3. **添加任务到队列**：每个线程都有自己的队列，你可以通过`offer()`方法向队列中添加任务。

executorA.submit(() -> {
    while (!queueA.isEmpty()) {
        Runnable task = queueA.take(); // 线程A从queueA取出任务
        task.run();
    }
});

executorB.submit(() -> {
    while (!queueB.isEmpty()) {
        Runnable task = queueB.take(); // 线程B从queueB取出任务
        task.run();
    }
});

4. **任务执行完成**：当线程执行完所有任务后，记得关闭线程池以释放系统资源。

executorA.shutdown();
executorB.shutdown();