jdk5 0 多執行緒學習筆記（五）

今天，我們來學學worker模式，大家也好對jdk5.0的執行緒池有乙個更好的理解。

先來看看**：

public class main 
}

再來看看傳送請求的client**：

public class clientthread extends thread 
public void run()  catch (interruptedexception e) 
}}

clientthread建立請求，並把請求傳給了channel，下面來看看channel類（相當於執行緒池類）

public class channel 
}public void startworkers() 
}public synchronized void putrequest(request request)  catch (interruptedexception e) 
}requestqueue[tail] = request;
tail = (tail + 1) % requestqueue.length;
count++;
notifyall();
}public synchronized request takerequest()  catch (interruptedexception e) 
}request request = requestqueue[head];
head = (head + 1) % requestqueue.length;
count--;
notifyall();
return request;
}}

channel類把傳給他的請求放入佇列中，等待worker去取請求，下面看看worker（即工作執行緒，執行緒池中已經初始話好的執行緒）

public class workerthread extends thread 
public void run() 
}}

在工作執行緒中會從執行緒池的佇列裡取出請求，並對請求進行處理。這裡的workerthread相當於背景執行緒，他一直都在執行，當有請求的時候，他就會進行處理，這裡處理請求的執行緒是已經存在在channel（執行緒池裡的執行緒），他不會因為請求的增加而增加（這是本例中的情況），不會來乙個請求就新建立乙個執行緒，節省了資源。

再看看請求的**：

public class request 
public void execute()  catch (interruptedexception e) 
}public string tostring() 
}

參考（多執行緒四）中所寫的 executorservice，其就相當於channel，即執行緒池。至於其實現當然要比channel複雜多了，channel只是舉個例子。而workerthread可不是工作執行緒，他相當於傳送到channel的請求，也就是request，當執行**：tpes.execute(workers[i]);時，相當於向執行緒池加入乙個請求，而

workerthread中的run則相當於request中的execute，這也是當執行tpes.execute(workers[i]);時，並不會產生新的執行緒的原因。（多執行緒四）中的寫法是讓人有些迷糊的。executorservice中產生的背景執行緒（相當於本篇的workerthread ）我們是看不到的。

jdk5中的多執行緒還有很多需要進一步學習，其實現也反應了多執行緒的設計模式。本篇的worker模式只是其中的一種。

jdk5 0 多執行緒學習筆記（五）

jdk執行緒池學習筆記

linux多執行緒學習筆記五執行緒安全

Java多執行緒學習筆記（五）執行緒池

jdk5 0 多執行緒學習筆記（五）

jdk執行緒池學習筆記

linux多執行緒學習筆記五 執行緒安全

Java多執行緒學習筆記（五）執行緒池

相關推薦

linux多執行緒學習筆記五執行緒安全