java線程學習案例（java線程總結）

本文目錄一覽：

• 1、java常用的幾種線程池實例講解
• 2、一個簡單java多線程的示例
• 3、JAVA多線程 編程題兩個案例，不會寫，求大神寫出代碼，萬分感謝，多線程還沒學。

java常用的幾種線程池實例講解

下面給你介紹4種線程池：

1、newCachedThreadPool：

底層：返回ThreadPoolExecutor實例，corePoolSize為0；maximumPoolSize為Integer.MAX_VALUE；keepAliveTime為60L；unit為TimeUnit.SECONDS；workQueue為SynchronousQueue(同步隊列)

通俗：當有新任務到來，則插入到SynchronousQueue中，由於SynchronousQueue是同步隊列，因此會在池中尋找可用線程來執行，若有可以線程則執行，若沒有可用線程則創建一個線程來執行該任務；若池中線程空閑時間超過指定大小，則該線程會被銷毀。

適用：執行很多短期異步的小程序或者負載較輕的服務器

2、newFixedThreadPool：

底層：返回ThreadPoolExecutor實例，接收參數為所設定線程數量nThread，corePoolSize為nThread，maximumPoolSize為nThread；keepAliveTime為0L(不限時)；unit為：TimeUnit.MILLISECONDS；WorkQueue為：new LinkedBlockingQueueRunnable() 無解阻塞隊列

通俗：創建可容納固定數量線程的池子，每隔線程的存活時間是無限的，當池子滿了就不在添加線程了；如果池中的所有線程均在繁忙狀態，對於新任務會進入阻塞隊列中(無界的阻塞隊列)

適用：執行長期的任務，性能好很多

3、newSingleThreadExecutor

底層：FinalizableDelegatedExecutorService包裝的ThreadPoolExecutor實例，corePoolSize為1；maximumPoolSize為1；keepAliveTime為0L；unit為：TimeUnit.MILLISECONDS；workQueue為：new LinkedBlockingQueueRunnable() 無解阻塞隊列

通俗：創建只有一個線程的線程池，且線程的存活時間是無限的；當該線程正繁忙時，對於新任務會進入阻塞隊列中(無界的阻塞隊列)

適用：一個任務一個任務執行的場景

4、NewScheduledThreadPool:

底層：創建ScheduledThreadPoolExecutor實例，corePoolSize為傳遞來的參數，maximumPoolSize為Integer.MAX_VALUE；keepAliveTime為0；unit為：TimeUnit.NANOSECONDS；workQueue為：new DelayedWorkQueue() 一個按超時時間升序排序的隊列

通俗：創建一個固定大小的線程池，線程池內線程存活時間無限制，線程池可以支持定時及周期性任務執行，如果所有線程均處於繁忙狀態，對於新任務會進入DelayedWorkQueue隊列中，這是一種按照超時時間排序的隊列結構

適用：周期性執行任務的場景

最後給你說一下線程池任務執行流程：

當線程池小於corePoolSize時，新提交任務將創建一個新線程執行任務，即使此時線程池中存在空閑線程。

當線程池達到corePoolSize時，新提交任務將被放入workQueue中，等待線程池中任務調度執行

當workQueue已滿，且maximumPoolSizecorePoolSize時，新提交任務會創建新線程執行任務

當提交任務數超過maximumPoolSize時，新提交任務由RejectedExecutionHandler處理

當線程池中超過corePoolSize線程，空閑時間達到keepAliveTime時，關閉空閑線程

當設置allowCoreThreadTimeOut(true)時，線程池中corePoolSize線程空閑時間達到keepAliveTime也將關閉

一個簡單java多線程的示例

for(int i=0;i10;i++){

System.out.println(name+”運行，i=”+i);

Thread.sleep(1)

}

for循環這樣改就行了，因為輸出10個數比較小，當你啟動啟動第二個線程時第一個線程已經運行完畢，所以兩次輸出都是順序輸出，要麼將i設置很大很大，要麼讓每次打印暫停一下

JAVA多線程 編程題兩個案例，不會寫，求大神寫出代碼，萬分感謝，多線程還沒學。

/*

class A extends Thread

{

public void run()

{

try

{

Thread.sleep(1000);

}catch(Exception e)

{

System.out.println(“A ERROR!”);

}

System.out.println(“AAAA”);

}

}

class B extends Thread

{

public void run()

{

try

{

Thread.sleep(2000);

}catch(Exception e)

{

System.out.println(“B ERROR!”);

}

System.out.println(“BBBB”);

}

}

class C extends Thread

{

public void run()

{

try

{

Thread.sleep(3000);

}catch(Exception e)

{

System.out.println(“C ERROR!”);

}

System.out.println(“CCCC”);

}

}

public class Test_1

{

public static void main(String[] args)

{

A a = new A();

B b = new B();

C c = new C();

a.start();

b.start();

c.start();

}

}*/

public class Test_1

{

public static void main(String[] args)

{

A a = new A();

B b = new B();

C c = new C();

Thread ta = new Thread(a);

Thread tb = new Thread(b);

Thread tc = new Thread(c);

ta.start();

tb.start();

tc.start();

}

}

class A implements Runnable

{

public void run()

{

try

{

Thread.sleep(1000);

}catch(Exception e)

{

System.out.println(“A ERROR!”);

}

System.out.println(“AAAA”);

}

}

class B implements Runnable

{

public void run()

{

try

{

Thread.sleep(2000);

}catch(Exception e)

{

System.out.println(“B ERROR!”);

}

System.out.println(“BBBB”);

}

}

class C implements Runnable

{

public void run()

{

try

{

Thread.sleep(3000);

}catch(Exception e)

{

System.out.println(“C ERROR!”);

}

System.out.println(“CCCC”);

}

}

案例一的兩種方法已經寫好；現在有事，晚上再把案例二代碼寫一下，應該沒關係吧！

抱歉，是一個線程類，我看錯了，晚上重發一下代碼！