java 异步线程队列实现的代码
时间: 2024-06-13 09:05:30 浏览: 179
以下是Java异步线程队列的实现代码示例:
```java
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
public class AsyncThreadQueue {
private static final int MAX_QUEUE_SIZE = 1000;
private BlockingQueue<Runnable> queue;
public AsyncThreadQueue() {
queue = new LinkedBlockingQueue<>(MAX_QUEUE_SIZE);
}
public void addTask(Runnable task) {
queue.offer(task);
}
public void start() {
new Thread(() -> {
while (true) {
try {
Runnable task = queue.take();
task.run();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}).start();
}
}
```
这段代码实现了一个异步线程队列,可以通过addTask方法向队列中添加任务,start方法启动异步线程,异步线程会不断从队列中取出任务并执行。
阅读全文