建站
咨詢
售后
建站咨詢
新聞中心
Java線程池需要我們不斷的學(xué)習(xí)，其實我們在使用的時候還是有不少問題需要我們解決。我們實現(xiàn)了一個簡單的Java線程池?，F(xiàn)在我們就可以使用它了，下面的代碼做了一個簡單的示例：
創(chuàng)新互聯(lián)公司成立與2013年，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項目成都網(wǎng)站制作、成都做網(wǎng)站網(wǎng)站策劃，項目實施與項目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元商城做網(wǎng)站,已為上家服務(wù),為商城各地企業(yè)和個人服務(wù),聯(lián)系電話:13518219792
Java代碼
- public class SimpleTaskTest extends Task {
- @Override
- public void deal() {
- // do something
- }
- public static void main(String[] args) throws InterruptedException {
- ThreadPoolService service = new ThreadPoolService();
- service.start();
- // 執(zhí)行十次任務(wù)
- for (int i = 0; i < 10; i++) {
- service.runTask(new SimpleTaskTest());
- }
- // 睡眠1秒鐘，等待所有任務(wù)執(zhí)行完畢
- Thread.sleep(1000);
- service.stop();
- }
- }
- public class SimpleTaskTest extends Task {
- @Override
- public void deal() {
- // do something
- }
- public static void main(String[] args) throws InterruptedException {
- ThreadPoolService service = new ThreadPoolService();
- service.start();
- // 執(zhí)行十次任務(wù)
- for (int i = 0; i < 10; i++) {
- service.runTask(new SimpleTaskTest());
- }
- // 睡眠1秒鐘，等待所有任務(wù)執(zhí)行完畢
- Thread.sleep(1000);
- service.stop();
- }
- }
當然，我們實現(xiàn)的是最簡單的，這里只是為了演示Java線程池的實現(xiàn)原理。在實際應(yīng)用中，根據(jù)情況的不同，可以做很多優(yōu)化。比如：
調(diào)整任務(wù)隊列的規(guī)則，給任務(wù)設(shè)置優(yōu)先級，級別高的任務(wù)優(yōu)先執(zhí)行。
動態(tài)維護Java線程池，當待執(zhí)行任務(wù)數(shù)量較多時，增加線程的數(shù)量，加快任務(wù)的執(zhí)行速度；當任務(wù)較少時，回收一部分長期閑置的Java線程池，減少對系統(tǒng)資源的消耗。
事實上Java5.0及以上版本已經(jīng)為我們提供了線程池功能，無需再重新實現(xiàn)。這些類位于java.util.concurrent包中。
Executors類提供了一組創(chuàng)建Java線程池對象的方法，常用的有一下幾個：
Java代碼
- public static ExecutorService newCachedThreadPool() {
- // other code
- }
- public static ExecutorService newFixedThreadPool(int nThreads) {
- // other code
- }
- public static ExecutorService newSingleThreadExecutor() {
- // other code
- }
- public static ExecutorService newCachedThreadPool() {
- // other code
- }
- public static ExecutorService newFixedThreadPool(int nThreads) {
- // other code
- }
- public static ExecutorService newSingleThreadExecutor() {
- // other code
- }
newCachedThreadPool()方法創(chuàng)建一個動態(tài)的線程池，其中線程的數(shù)量會根據(jù)實際需要來創(chuàng)建和回收，適合于執(zhí)行大量短期任務(wù)的情況；newFixedThreadPool(int nThreads)方法創(chuàng)建一個包含固定數(shù)量線程對象的Java線程池，nThreads代表要創(chuàng)建的線程數(shù)，如果某個線程在運行的過程中因為異常而終止了，那么一個新的線程會被創(chuàng)建和啟動來代替它；而newSingleThreadExecutor()方法則只在線程池中創(chuàng)建一個線程，來執(zhí)行所有的任務(wù)。
當前文章：Java線程池在使用中的問題解疑
轉(zhuǎn)載注明：http://m.fisionsoft.com.cn/article/dhidhpc.html
