繼承 Thread 類創(chuàng)建線程類
Thread 的實現(xiàn)步驟:
- 定義 Thread 的子類,重寫 run()方法,run()方法代表了線程要完成的任務,run()方法稱為線程執(zhí)行體。
- 創(chuàng)建 Thread 子類的實例,子類對象就是線程。
- 調(diào)用線程對象的 start()方法來啟動線程。
public class ThreadDemo extends Thread{
?
public void run() {
for(int i=0;i<10;i++) {
System.out.println(currentThread().getName()+":" + i);
}
}
?
public static void main(String args[]) {
new ThreadDemo().start();
new ThreadDemo().start();
}
}
運行結(jié)果:
實現(xiàn) Runnable 接口創(chuàng)建線程類
Runnable的實現(xiàn)步驟:
- 定義 Runnable 接口實現(xiàn)類,重寫 run()方法,run() 方法代表了線程要完成的任務,run()方法稱為線程執(zhí)行體。
- 創(chuàng)建 Runnable 實現(xiàn)類的實例,Runnable 本身就是 Thread 類的方法,所以創(chuàng)建線程還要實現(xiàn)一個 Thread 類來包裝 Runnable 對象。
- 調(diào)用線程對象的 start() 方法來啟動線程。
public class RunnableDemo implements Runnable{
?
String threadName;
?
public RunnableDemo(String threadName) {
this.threadName = threadName;
}
?
@Override
public void run() {
for(int i=0;i<10;i++) {
System.out.println(threadName+":" + i);
}
}
?
public static void main(String args[]) {
new Thread(new RunnableDemo("A")).start();
new Thread(new RunnableDemo("B")).start();
}
}
運行結(jié)果:
實現(xiàn) Callable 接口創(chuàng)建線程類
從 Java5 開始就提供了 Callable 接口,該接口是 Runnable 接口的增強版,Callable 接口提供一個 call() 方法作為線程執(zhí)行體,call()方法可以有返回值,call() 方法可以聲明拋出異常。
- ?
boolean cancel(boolean may)
?試圖取消該 Future 里關(guān)聯(lián)的 Callable 任務。 - ?
V get()
?返回 Call 任務里 call() 方法的返回值。調(diào)用該方法會照成線程阻塞,必須等待子線程結(jié)束后才會得到返回值。 - ?
V get(long timeout,TimeUnit unit)
?返回 Call 任務里 call() 方法的返回值。該方法讓程序最多阻塞 timeout 和 unit 指定的時間,如果經(jīng)過指定的時間,如果經(jīng)過指定的時間依然沒有返回值,將會拋出 TimeoutException 異常。 - ?
boolean isCancelled()
?如果在 Callable 任務正常完成前被取消,則返回 true。 - ?
boolean isDone()
?如果 Callable 任務已完成,則返回 true。
Runnable的實現(xiàn)步驟:
- 創(chuàng)建 Callable 接口的實現(xiàn)類,并實現(xiàn) call() 方法,該 call() 方法作為線程的執(zhí)行體,call() 方法有返回值。
- 使用 FutrueTask 類包裝 Callable 對象。
- 使用 FutrueTask 對象作為Thread 對象的 target 創(chuàng)建并啟動新線程。
- 啟用 FutrueTask 對象的 get() 方法來獲得子線程的返回值。
public class CallableDemo implements Callable<Integer> {
public static void main(String args[]) {
FutureTask<Integer> futureTask = new FutureTask<Integer>(new CallableDemo());
new Thread(futureTask).start();
try {
System.out.println("子線程返回值:" + futureTask.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
if (futureTask.isDone()) {
System.out.println("線程結(jié)束");
}
}
?
@Override
public Integer call() throws Exception {
System.out.println("線程開始");
int ss = 0;
for (int i = 0; i < 20; i++) {
ss += i;
}
return ss;
}
}
運行結(jié)果: