Java多線程實(shí)現(xiàn)四種方式原理詳解
1.繼承Thread類,重寫run方法
2.實(shí)現(xiàn)Runnable接口,重寫run方法,實(shí)現(xiàn)Runnable接口的實(shí)現(xiàn)類的實(shí)例對(duì)象作為Thread構(gòu)造函數(shù)的target
3.通過Callable和FutureTask創(chuàng)建線程
4.通過線程池創(chuàng)建線程
前面兩種可以歸結(jié)為一類:無返回值,原因很簡(jiǎn)單,通過重寫run方法,run方式的返回值是void,所以沒有辦法返回結(jié)果
后面兩種可以歸結(jié)成一類:有返回值,通過Callable接口,就要實(shí)現(xiàn)call方法,這個(gè)方法的返回值是Object,所以返回的結(jié)果可以放在Object對(duì)象中
1. 繼承Thread類
public class ThreadDemo01 extends Thread{ public ThreadDemo01(){ //編寫子類的構(gòu)造方法,可缺省 } 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()); }}
程序結(jié)果:
Thread[main,5,main]我是自定義的線程1
2. 實(shí)現(xiàn)Runnable接口
重寫run方法,接口的實(shí)現(xiàn)類的實(shí)例作為Thread的target作為參數(shù)傳入帶參的Thread構(gòu)造函數(shù),通過調(diào)用start()方法啟動(dòng)線程
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()+'-->我是通過實(shí)現(xiàn)接口的線程實(shí)現(xiàn)方式!'); } }
程序運(yùn)行結(jié)果:
mainThread-0?>我是通過實(shí)現(xiàn)接口的線程實(shí)現(xiàn)方式!
3. 通過Callable和FutureTask創(chuàng)建線程
創(chuàng)建Callable接口的實(shí)現(xiàn)類 ,并實(shí)現(xiàn)Call方法 創(chuàng)建Callable實(shí)現(xiàn)類的實(shí)現(xiàn),使用FutureTask類包裝Callable對(duì)象,該FutureTask對(duì)象封裝了Callable對(duì)象的Call方法的返回值 使用FutureTask對(duì)象作為Thread對(duì)象的target創(chuàng)建并啟動(dòng)線程 調(diào)用FutureTask對(duì)象的get()來獲取子線程執(zhí)行結(jié)束的返回值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()+'-->我是通過實(shí)現(xiàn)Callable接口通過FutureTask包裝器來實(shí)現(xiàn)的線程'); return null; } }
程序運(yùn)行結(jié)果:
mainThread-0?>我是通過實(shí)現(xiàn)Callable接口通過FutureTask包裝器來實(shí)現(xiàn)的線程
4. 通過線程池創(chuàng)建線程
public class ThreadDemo05{ private static int POOL_NUM = 10; //線程池?cái)?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); } //關(guān)閉線程池 executorService.shutdown(); } }class RunnableThread implements Runnable { @Override public void run() { System.out.println('通過線程池方式創(chuàng)建的線程:' + Thread.currentThread().getName() + ' '); } }
程序運(yùn)行結(jié)果:
通過線程池方式創(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接口也是屬于這個(gè)框架,有了這種特征得到返回值就很方便了。通過分析可以知道,他同樣也是實(shí)現(xiàn)了Callable接口,實(shí)現(xiàn)了Call方法,所以有返回值。這也就是正好符合了前面所說的兩種分類執(zhí)行Callable任務(wù)后,可以獲取一個(gè)Future的對(duì)象,在該對(duì)象上調(diào)用get就可以獲取到Callable任務(wù)返回的Object了。get方法是阻塞的,即:線程無返回結(jié)果,get方法會(huì)一直等待。
Executors類:提供了一系列工廠方法用于創(chuàng)建線程池,返回的線程池都實(shí)現(xiàn)了ExecutorService接口。
// 創(chuàng)建固定數(shù)目線程的線程池public static ExecutorService newFixedThreadPool(int nThreads)
// 創(chuàng)建一個(gè)可緩存的線程池,調(diào)用execute 將重用以前構(gòu)造的線程(如果線程可用)。如果現(xiàn)有線程沒有可用的,則創(chuàng)建一個(gè)新線程并添加到池中。終止并從緩存中移除那些已有 60 秒鐘未被使用的線程public static ExecutorService newCachedThreadPool()
// 創(chuàng)建一個(gè)單線程化的Executorpublic static ExecutorService newSingleThreadExecutor()
// 創(chuàng)建一個(gè)支持定時(shí)及周期性的任務(wù)執(zhí)行的線程池,多數(shù)情況下可用來替代Timer類public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
ExecutoreService提供了submit()方法,傳遞一個(gè)Callable,或Runnable,返回Future。
如果Executor后臺(tái)線程池還沒有完成Callable的計(jì)算,這調(diào)用返回Future對(duì)象的get()方法,會(huì)阻塞直到計(jì)算完成。
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. Xml簡(jiǎn)介_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理2. UDDI FAQs3. 低版本IE正常運(yùn)行HTML5+CSS3網(wǎng)站的3種解決方案4. ASP常用日期格式化函數(shù) FormatDate()5. 將properties文件的配置設(shè)置為整個(gè)Web應(yīng)用的全局變量實(shí)現(xiàn)方法6. CSS可以做的幾個(gè)令你嘆為觀止的實(shí)例分享7. JSP+Servlet實(shí)現(xiàn)文件上傳到服務(wù)器功能8. jsp+servlet實(shí)現(xiàn)猜數(shù)字游戲9. jsp文件下載功能實(shí)現(xiàn)代碼10. JSP之表單提交get和post的區(qū)別詳解及實(shí)例
