來至《java多線程設計模式》

類似ThreadPool，預先產生幾個worker線程準備工作。

public void startWorkers() {for (int i = 0; i < threadPool.length; i++) {threadPool[i].start();}} package Sample;public class WorkerThread extends Thread {private final Channel channel;public WorkerThread(String name, Channel channel) {super(name);this.channel = channel;}public void run() {while (true) {}} } public synchronized void putRequest(Request request) {while (count >= requestQueue.length) {try {wait();} catch (InterruptedException e) {}}requestQueue[tail] = request;tail = (tail + 1) % requestQueue.length;count++;notifyAll();}public synchronized Request takeRequest() {while (count <= 0) {try {wait();} catch (InterruptedException e) {}}Request request = requestQueue[head];head = (head + 1) % requestQueue.length;count--;notifyAll();return request;}

轉載于:https://www.cnblogs.com/cxccbv/archive/2009/05/08/1452954.html

總結

以上是生活随笔為你收集整理的模式8--WorkerThread的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。