溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章給大家分享的是有關worker模式的示例代碼的內容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。
public class Main {
public static void main(String[] args) {
Channel channel = new Channel(5); // 工人線程的數量,即線程池內的線程數目
channel.startWorkers();//啟動線程池內的線程
new ClientThread("Alice", channel).start();//發送請求的線程，相當于向隊列加入請求
new ClientThread("Bobby", channel).start();
new ClientThread("Chris", channel).start();
}
}
發送請求的client代碼：
public class ClientThread extends Thread {
private final Channel channel;//相當于線程池
private static final Random random = new Random();
public ClientThread(String name, Channel channel) {
super(name);
this.channel = channel;
}
public void run() {
try {
int i = 0;
Request request = new Request(getName(), i);//生成請求
channel.putRequest(request);//向隊列中放入請求，也即把請求傳給線程池
Thread.sleep(random.nextInt(1000));
} catch (InterruptedException e) {
}
}
}
ClientThread建立請求，并把請求傳給了channel，下面來看看channel類（相當于線程池類）
public class Channel {
private static final int MAX_REQUEST = 100;
private final Request[] requestQueue;//存放請求的隊列
private int tail; // 下一個putRequest的地方
private int head; // 下一個takeRequest的地方
private int count; // Request的數量
private final WorkerThread[] threadPool;
public Channel(int threads) {
this.requestQueue = new Request[MAX_REQUEST];
this.head = 0;
this.tail = 0;
this.count = 0;
threadPool = new WorkerThread[threads];
for (int i = 0; i < threadPool.length; i++) {
threadPool[i] = new WorkerThread("Worker-" + i, this);//生成線程池中的線程
}
}
public void startWorkers() {
for (int i = 0; i < threadPool.length; i++) {
threadPool[i].start();//啟動線程池中的線程
}
}
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;
}
}
channel類把傳給他的請求放入隊列中，等待worker去取請求，下面看看worker（即工作線程，線程池中已經初始話好的線程）
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) {
Request request = channel.takeRequest();//取出請求
request.execute();//處理請求
}
}
}
在工作線程中會從線程池的隊列里取出請求，并對請求進行處理。這里的workerthread相當于背景線程，他一直都在運行，當有請求的時候，他就會進行處理，這里處理請求的線程是已經存在在channel（線程池里的線程），他不會因為請求的增加而增加（這是本例中的情況），不會來一個請求就新建立一個線程，節省了資源。
再看看請求的代碼：
public class Request {
private final String name; // 委托者
private final int number; // 請求編號
private static final Random random = new Random();
public Request(String name, int number) {
this.name = name;
this.number = number;
}
public void execute() {//執行請求
System.out.println(Thread.currentThread().getName() + " executes " + this);
try {
Thread.sleep(random.nextInt(1000));
} catch (InterruptedException e) {
}
}
public String toString() {
return "[ Request from " + name + " No." + number + " ]";
}
}
JAVA SDK所寫的 ExecutorService，其就相當于channel，即線程池。至于其實現當然要比channel復雜多了，channel只是舉個例子。而WorkerThread可不是工作線程，他相當于發送到channel的請求，也就是request，當執行代碼：tpes.execute(workers[i]);時，相當于向線程池加入一個請求，而WorkerThread中的run則相當于request中的execute，這也是當執行tpes.execute(workers[i]);時，并不會產生新的線程的原因。ExecutorService中產生的背景線程（相當于本篇的WorkerThread ）我們是看不到的。
感謝各位的閱讀！關于“worker模式的示例代碼”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
