色综合图-色综合图片-色综合图片二区150p-色综合图区-玖玖国产精品视频-玖玖香蕉视频

您的位置:首頁技術文章
文章詳情頁

Java多線程實現(xiàn)四種方式原理詳解

瀏覽:2日期:2022-08-31 17:26:20

1.繼承Thread類,重寫run方法

2.實現(xiàn)Runnable接口,重寫run方法,實現(xiàn)Runnable接口的實現(xiàn)類的實例對象作為Thread構造函數(shù)的target

3.通過Callable和FutureTask創(chuàng)建線程

4.通過線程池創(chuàng)建線程

前面兩種可以歸結為一類:無返回值,原因很簡單,通過重寫run方法,run方式的返回值是void,所以沒有辦法返回結果

后面兩種可以歸結成一類:有返回值,通過Callable接口,就要實現(xiàn)call方法,這個方法的返回值是Object,所以返回的結果可以放在Object對象中

1. 繼承Thread類

public class ThreadDemo01 extends Thread{ public ThreadDemo01(){ //編寫子類的構造方法,可缺省 } public void run(){ //編寫自己的線程代碼 System.out.println(Thread.currentThread().getName()); } public static void main(String[] args){ ThreadDemo01 threadDemo01 = new ThreadDemo01(); threadDemo01.setName('我是自定義的線程1'); threadDemo01.start();System.out.println(Thread.currentThread().toString()); }}

程序結果:

Thread[main,5,main]我是自定義的線程1

2. 實現(xiàn)Runnable接口

重寫run方法,接口的實現(xiàn)類的實例作為Thread的target作為參數(shù)傳入帶參的Thread構造函數(shù),通過調(diào)用start()方法啟動線程

public class ThreadDemo02 { public static void main(String[] args){ System.out.println(Thread.currentThread().getName()); Thread t1 = new Thread(new MyThread()); t1.start(); }}class MyThread implements Runnable{ @Override public void run() { // TODO Auto-generated method stub System.out.println(Thread.currentThread().getName()+'-->我是通過實現(xiàn)接口的線程實現(xiàn)方式!'); } }

程序運行結果:

mainThread-0?>我是通過實現(xiàn)接口的線程實現(xiàn)方式!

3. 通過Callable和FutureTask創(chuàng)建線程

創(chuàng)建Callable接口的實現(xiàn)類 ,并實現(xiàn)Call方法 創(chuàng)建Callable實現(xiàn)類的實現(xiàn),使用FutureTask類包裝Callable對象,該FutureTask對象封裝了Callable對象的Call方法的返回值 使用FutureTask對象作為Thread對象的target創(chuàng)建并啟動線程 調(diào)用FutureTask對象的get()來獲取子線程執(zhí)行結束的返回值

public class ThreadDemo03 { /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub Callable<Object> oneCallable = new Tickets<Object>(); FutureTask<Object> oneTask = new FutureTask<Object>(oneCallable); Thread t = new Thread(oneTask); System.out.println(Thread.currentThread().getName()); t.start(); }}class Tickets<Object> implements Callable<Object>{ //重寫call方法 @Override public Object call() throws Exception { // TODO Auto-generated method stub System.out.println(Thread.currentThread().getName()+'-->我是通過實現(xiàn)Callable接口通過FutureTask包裝器來實現(xiàn)的線程'); return null; } }

程序運行結果:

mainThread-0?>我是通過實現(xiàn)Callable接口通過FutureTask包裝器來實現(xiàn)的線程

4. 通過線程池創(chuàng)建線程

public class ThreadDemo05{ private static int POOL_NUM = 10; //線程池數(shù)量 /** * @param args * @throws InterruptedException */ public static void main(String[] args) throws InterruptedException { // TODO Auto-generated method stub ExecutorService executorService = Executors.newFixedThreadPool(5); for(int i = 0; i<POOL_NUM; i++) { RunnableThread thread = new RunnableThread(); //Thread.sleep(1000); executorService.execute(thread); } //關閉線程池 executorService.shutdown(); } }class RunnableThread implements Runnable { @Override public void run() { System.out.println('通過線程池方式創(chuàng)建的線程:' + Thread.currentThread().getName() + ' '); } }

程序運行結果:

通過線程池方式創(chuàng)建的線程:pool-1-thread-3通過線程池方式創(chuàng)建的線程:pool-1-thread-4通過線程池方式創(chuàng)建的線程:pool-1-thread-1通過線程池方式創(chuàng)建的線程:pool-1-thread-5通過線程池方式創(chuàng)建的線程:pool-1-thread-2通過線程池方式創(chuàng)建的線程:pool-1-thread-5通過線程池方式創(chuàng)建的線程:pool-1-thread-1通過線程池方式創(chuàng)建的線程:pool-1-thread-4通過線程池方式創(chuàng)建的線程:pool-1-thread-3通過線程池方式創(chuàng)建的線程:pool-1-thread-2

ExecutorService、Callable都是屬于Executor框架。還有Future接口也是屬于這個框架,有了這種特征得到返回值就很方便了。通過分析可以知道,他同樣也是實現(xiàn)了Callable接口,實現(xiàn)了Call方法,所以有返回值。這也就是正好符合了前面所說的兩種分類執(zhí)行Callable任務后,可以獲取一個Future的對象,在該對象上調(diào)用get就可以獲取到Callable任務返回的Object了。get方法是阻塞的,即:線程無返回結果,get方法會一直等待。

Executors類:提供了一系列工廠方法用于創(chuàng)建線程池,返回的線程池都實現(xiàn)了ExecutorService接口。

// 創(chuàng)建固定數(shù)目線程的線程池public static ExecutorService newFixedThreadPool(int nThreads)

// 創(chuàng)建一個可緩存的線程池,調(diào)用execute 將重用以前構造的線程(如果線程可用)。如果現(xiàn)有線程沒有可用的,則創(chuàng)建一個新線程并添加到池中。終止并從緩存中移除那些已有 60 秒鐘未被使用的線程public static ExecutorService newCachedThreadPool()

// 創(chuàng)建一個單線程化的Executorpublic static ExecutorService newSingleThreadExecutor()

// 創(chuàng)建一個支持定時及周期性的任務執(zhí)行的線程池,多數(shù)情況下可用來替代Timer類public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)

ExecutoreService提供了submit()方法,傳遞一個Callable,或Runnable,返回Future。

如果Executor后臺線程池還沒有完成Callable的計算,這調(diào)用返回Future對象的get()方法,會阻塞直到計算完成。

以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網(wǎng)。

標簽: Java
相關文章:
主站蜘蛛池模板: 初爱视频教程在线观看高清 | 国产成人精品日本亚洲网站 | 免费一级肉体全黄毛片 | 亚洲国产欧洲综合997久久 | 亚洲人成网址在线播放a | 美女视频黄的免费看网站 | 久久精品在线 | 国产成人啪一区二区 | 中国一级片免费看 | 午夜免费理论片a级 | 亚洲综合精品 | 在线视频亚洲 | 精品欧美日韩一区二区三区 | 一a一片一级一片啪啪 | 免费特黄一级欧美大片在线看 | 国产精品一区二区三区四区五区 | 寡妇野外啪啪一区二区 | 欧美13一14周岁a在线播放 | 欧美一级淫片免费播放口 | 天天躁夜夜躁狠狠躁2024 | 国产精品合集一区二区 | 欧美成人午夜毛片免费影院 | 国产91精品一区二区麻豆亚洲 | 色综合天天综合网看在线影院 | 九九热视频精品在线观看 | 91精品免费高清在线 | 日韩久久精品 | 国产一级一片免费播放i | 全部孕妇毛片丰满孕妇孕交 | 美女扒开腿让男人桶个爽 | 亚洲一区 在线播放 | 黄网在线观看免费网站台湾swag | 久久不见久久见免费影院 | 成人软件18免费 | 欧美一线不卡在线播放 | 午夜视频在线观看一区 | 国产成人免费视频精品一区二区 | 一级做a爱 一区 | 久久精品视频免费看 | 国产真实搭讪系列 | 一级特黄aaa大片在线观看 |