Java中創(chuàng)建線程主要有三種方式:
一、繼承Thread類創(chuàng)建線程類
(1)定義Thread類的子類,并重寫該類的run方法,該run方法的方法體就代表了線程要完成的任務(wù)。因此把run()方法稱為執(zhí)行體。
(2)創(chuàng)建Thread子類的實例,即創(chuàng)建了線程對象。
(3)調(diào)用線程對象的start()方法來啟動該線程。
[java]?view plain?copy
package?com.thread;??
public?class?FirstThreadTest?extends?Thread{??
int?i?=?0;??
//重寫run方法,run方法的方法體就是現(xiàn)場執(zhí)行體??
public?void?run()??
????{??
for(;i<100;i++){??
System.out.println(getName()+"??"+i);??
????????}??
????}??
public?static?void?main(String[]?args)??
????{??
for(int?i?=?0;i<?100;i++)??
????????{??
System.out.println(Thread.currentThread().getName()+"??:?"+i);??
if(i==20)??
????????????{??
new?FirstThreadTest().start();??
new?FirstThreadTest().start();??
????????????}??
????????}??
????}??
}??
上述代碼中Thread.currentThread()方法返回當(dāng)前正在執(zhí)行的線程對象。GetName()方法返回調(diào)用該方法的線程的名字。
二、通過Runnable接口創(chuàng)建線程類
(1)定義runnable接口的實現(xiàn)類,并重寫該接口的run()方法,該run()方法的方法體同樣是該線程的線程執(zhí)行體。
(2)創(chuàng)建 Runnable實現(xiàn)類的實例,并依此實例作為Thread的target來創(chuàng)建Thread對象,該Thread對象才是真正的線程對象。
(3)調(diào)用線程對象的start()方法來啟動該線程。
示例代碼為:
[java]?view plain?copy
package?com.thread;??
public?class?RunnableThreadTest?implements?Runnable??
{??
private?int?i;??
public?void?run()??
????{??
for(i?=?0;i?<100;i++)??
????????{??
System.out.println(Thread.currentThread().getName()+"?"+i);??
????????}??
????}??
public?static?void?main(String[]?args)??
????{??
for(int?i?=?0;i?<?100;i++)??
????????{??
System.out.println(Thread.currentThread().getName()+"?"+i);??
if(i==20)??
????????????{??
RunnableThreadTest?rtt?=new?RunnableThreadTest();??
new?Thread(rtt,"新線程1").start();??
new?Thread(rtt,"新線程2").start();??
????????????}??
????????}??
????}??
}??
三、通過Callable和Future創(chuàng)建線程(AsyncTask 中使用這種)
(1)創(chuàng)建Callable接口的實現(xiàn)類,并實現(xiàn)call()方法,該call()方法將作為線程執(zhí)行體,并且有返回值。
(2)創(chuàng)建Callable實現(xiàn)類的實例,使用FutureTask類來包裝Callable對象,該FutureTask對象封裝了該Callable對象的call()方法的返回值。
(3)使用FutureTask對象作為Thread對象的target創(chuàng)建并啟動新線程。
(4)調(diào)用FutureTask對象的get()方法來獲得子線程執(zhí)行結(jié)束后的返回值
實例代碼:
[java]?view plain?copy
package?com.thread;??
import?java.util.concurrent.Callable;??
import?java.util.concurrent.ExecutionException;??
import?java.util.concurrent.FutureTask;??
public?class?CallableThreadTest?implements?Callable??
{??
public?static?void?main(String[]?args)??
????{??
CallableThreadTest?ctt?=new?CallableThreadTest();??
FutureTask?ft?=new?FutureTask<>(ctt);??
for(int?i?=?0;i?<?100;i++)??
????????{??
System.out.println(Thread.currentThread().getName()+"?的循環(huán)變量i的值"+i);??
if(i==20)??
????????????{??
new?Thread(ft,"有返回值的線程").start();??
????????????}??
????????}??
try??
????????{??
System.out.println("子線程的返回值:"+ft.get());??
}catch?(InterruptedException?e)??
????????{??
????????????e.printStackTrace();??
}catch?(ExecutionException?e)??
????????{??
????????????e.printStackTrace();??
????????}??
????}??
@Override??
public?Integer?call()?throws?Exception??
????{??
int?i?=?0;??
for(;i<100;i++)??
????????{??
System.out.println(Thread.currentThread().getName()+"?"+i);??
????????}??
return?i;??
????}??
}??