java線程池筆記：
線程池好處：
重用存在的線程，減少對(duì)象創(chuàng)建、消亡的開銷，性能佳。

可有效控制最大并發(fā)線程數(shù)，提高系統(tǒng)資源的使用率，同時(shí)避免過多資源競(jìng)爭(zhēng)，避免堵塞。

提供定時(shí)執(zhí)行、定期執(zhí)行、單線程、并發(fā)數(shù)控制等功能。

java提供四個(gè)常用線程池
1.Executors是線程池頂級(jí)類。
2.ExecutorService 線程池類型.execute();
可緩存：newCachedThreadPool();
并發(fā)數(shù)控制：newFixedThreadPool(int num);
單線程：newSingelThreadPool();
定時(shí)執(zhí)行、定期執(zhí)行：newScheduledThreadPool();其二方法scheduleAtFixedRate(new Thread(), init延遲, 周期, TimeUnit.SECONDS);/scheduledthread.schedule(thread,time,unit);

代碼實(shí)現(xiàn)：

/*** java線程池* @author joker*/ package com.Threadp;import java.util.Random; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit;class Threadtest implements Runnable {public int index;public Threadtest(int ind) {this.index = ind;}@Overridepublic void run() {// TODO 自動(dòng)生成的方法存根System.out.print("\n第" + index + "線程被喚醒。。");int i = 0;while (i < 4) {try {Thread.sleep(500);System.out.print(index + "->");} catch (InterruptedException e) {// TODO 自動(dòng)生成的 catch 塊e.printStackTrace();}i++;}} }public class Threadpool {public static void main(String[] args) {// TODO 自動(dòng)生成的方法存根// Executors線程池父類java.util.concurrent.Executor// 線程池好處：回收線程創(chuàng)立與消耗造成的不必要消耗// 高并發(fā)處理/*** newCachedThreadPool創(chuàng)建一個(gè)可緩存線程池，如果線程池長(zhǎng)度超過處理需要，可靈活回收空閑線程，若無可回收，則新建線程。* newFixedThreadPool 創(chuàng)建一個(gè)定長(zhǎng)線程池，可控制線程最大并發(fā)數(shù)，超出的線程會(huì)在隊(duì)列中等待。 newScheduledThreadPool* 創(chuàng)建一個(gè)定長(zhǎng)線程池，支持定時(shí)及周期性任務(wù)執(zhí)行。 newSingleThreadExecutor* 創(chuàng)建一個(gè)單線程化的線程池，它只會(huì)用唯一的工作線程來執(zhí)行任務(wù)，保證所有任務(wù)按照指定順序(FIFO, LIFO, 優(yōu)先級(jí))執(zhí)行。* *//** 可緩存的線程池 線程池為無限大，當(dāng)執(zhí)行第二個(gè)任務(wù)時(shí)第一個(gè)任務(wù)已經(jīng)完成，會(huì)復(fù)用執(zhí)行第一個(gè)任務(wù)的線程，而不用每次新建線程。*/System.out.println("\n===========================================");ExecutorService cachedthread = Executors.newCachedThreadPool();System.out.println("可緩存線程池創(chuàng)建。。。" + "&(等待執(zhí)行性)");for (int i = 0; i < 3; i++) {try {Thread.sleep(i * 1000);System.out.println(i + "新線程被創(chuàng)建");} catch (InterruptedException e) {// TODO 自動(dòng)生成的 catch 塊e.printStackTrace();}cachedthread.execute(new Runnable() {@Overridepublic void run() {// TODO 自動(dòng)生成的方法存根System.out.println("新線程被喚醒");}});}cachedthread.shutdown();System.out.println("\n可緩存線程池銷毀。。。");/** 定長(zhǎng)線程池 可控制線程最大并發(fā)數(shù)，超出的線程會(huì)在隊(duì)列中等待*/System.out.println("\n===========================================");ExecutorService fixedthread = Executors.newFixedThreadPool(3);System.out.println("\n\n定長(zhǎng)線程池創(chuàng)建。。。(長(zhǎng)度3)" + "&(超出線程池則線程等待)");for (int i = 1; i < 6; i++)fixedthread.execute(new Threadtest(i));try {Thread.sleep(10000);} catch (InterruptedException e) {// TODO 自動(dòng)生成的 catch 塊e.printStackTrace();}fixedthread.shutdown();System.out.println("\n===========================================");System.out.println("\n定長(zhǎng)線程池銷毀。。。等待執(zhí)行型");System.out.println("\n\n定長(zhǎng)線程池創(chuàng)建。。。" + "&(周期性執(zhí)行，延遲執(zhí)行)");ScheduledExecutorService scheduledthread = Executors.newScheduledThreadPool(4);// 周期執(zhí)行System.out.println("周期執(zhí)行2秒");// scheduleAtFixedRate(new Thread(), init延遲, 周期, TimeUnit.SECONDS);scheduledthread.scheduleAtFixedRate(new Threadtest(new Random().nextInt(5)), 0, 2, TimeUnit.SECONDS);System.out.println("延遲執(zhí)行");scheduledthread.schedule(new Runnable() {@Overridepublic void run() {// TODO 自動(dòng)生成的方法存根System.out.println("延遲執(zhí)行5秒\n");}}, 5, TimeUnit.SECONDS);try {Thread.sleep(7000);} catch (InterruptedException e) {// TODO 自動(dòng)生成的 catch 塊e.printStackTrace();}scheduledthread.shutdown();System.out.println("\n定長(zhǎng)線程池銷毀。。。周延型");System.out.println("\n===========================================");System.out.println("\n\n定長(zhǎng)線程池創(chuàng)建。。。" + "&(單線程池)");ExecutorService singelthread=Executors.newSingleThreadExecutor();singelthread.execute(new Threadtest(9999));try {Thread.sleep(8000);} catch (InterruptedException e) {// TODO 自動(dòng)生成的 catch 塊e.printStackTrace();}singelthread.shutdown();System.out.println("\n定長(zhǎng)線程池銷毀。。。單線程池型");}}

總結(jié)

以上是生活随笔為你收集整理的java线程池笔记及相关代码的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。