Java建立執行緒的三種方式
阿新 • • 發佈:2018-12-09
繼承Thread
(1)定義Thread類的子類,重寫該類的run方法,該run方法的方法體就代表了執行緒要完成的任務。因此把run()方法稱為執行體。 (2)建立Thread子類的例項,即建立了執行緒物件。 (3)呼叫執行緒物件的start()方法來啟動該執行緒。
class thread extends Thread {
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
}
}
public class ThreadTest1 {
public static void main(String[] args){
System.out.println(Thread.currentThread().getName());
for(int i = 0;i<5;i++){
new thread().start();
}
}
}
實現Runnable介面
(1)定義runnable介面的實現類,並重寫該介面的run()方法,該run()方法的方法體是該執行緒的執行緒執行體。 (2)建立 Runnable實現類的例項,並依此例項作為Thread的target來建立Thread物件,該Thread物件才是真正的執行緒物件。 (3)呼叫執行緒物件的start()方法來啟動該執行緒。
class ThreadRunnable implements Runnable {
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
}
}
public class ThreadTest3 {
public static void main(String[] args){
System.out.println(Thread.currentThread().getName());
for(int i = 0;i<5;i++){
ThreadRunnable threadRunnable = new ThreadRunnable();
new Thread(threadRunnable).start();
}
}
}
也可以使用匿名內部類的方式
public class ThreadTest2 {
public static void main(String[] args){
System.out.println(Thread.currentThread().getName());
for(int i = 0;i<5;i++){
new Thread(new Runnable() {
@Override
public void run() {
System.out.println(Thread.currentThread().getName());
}
}).start();
}
}
}
使用Callable和FutureTask
(1)建立Callable介面的實現類,並實現call()方法,該call()方法將作為執行緒執行體,並且有返回值。 (2)建立Callable實現類的例項,使用FutureTask類來包裝Callable物件,該FutureTask物件封裝了該Callable物件的call()方法的返回值。 (3)使用FutureTask物件作為Thread物件的target建立並啟動新執行緒。 (4)呼叫FutureTask物件的get()方法來獲得子執行緒執行結束後的返回值
class CallableThread implements Callable<Integer>{
private Integer score;
public CallableThread(int score){
this.score = score;
}
@Override
public Integer call() throws Exception {
return score;
}
}
public class ThreadTest4 {
public static void main(String[] args){
System.out.println(Thread.currentThread().getName());
CallableThread callableThread = new CallableThread(100);
FutureTask<Integer> ft = new FutureTask<Integer>(callableThread);
new Thread(ft,"with back result").start();
try {
System.out.println(ft.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}