1. 程式人生 > >java併發之----執行緒的建立方法

java併發之----執行緒的建立方法

一、執行緒的建立

(1)繼承Thread類

需要實現run方法,通過呼叫start方法啟動執行緒

public class MyThread extends Thread{
	@Override
	public void run(){//實現run方法
		//以下根據自己的需要來寫,這裡列印示例1~9
		for(int i=1; i<10; i++){
			System.out.print(i + " ");
		}
	}
}
public class TestMyThread {
	public static void main(String[] args) {
		MyThread m1 =
new MyThread(); m1.start(); } }

在這裡插入圖片描述

(2)實現Runnable介面

同樣需要實現run方法,通過Thread呼叫start()方法來啟動執行緒
與Callable相比,沒有返回值

public class MyRunnable implements Runnable{
	@Override
	public void run() {//同樣需要實現run方法
		for(int i=0; i<10; i++){
			System.out.print(i + " ");
		}
	}
}
public class TestMyRunnable
{ public static void main(String[] args){ MyRunnable mr = new MyRunnable(); //通過Thread呼叫start()方法來啟動執行緒 Thread thread = new Thread(mr); thread.start(); } }

在這裡插入圖片描述

(3)實現Callable介面

與Runnable相比,Callable提供了call()方法作為執行緒執行體,類似於run方法,但功能更加強大。
Callable可以有返回值,返回值需要通過FutureTask 進行封裝。FutureTask 實現了Future介面和Runnable介面,因而也需要通過Thread呼叫start()方法來啟動執行緒

public class MyCallable implements Callable<Integer> {
	@Override
	public Integer call() throws Exception {//實現call方法
		int i=0;
		for(; i<10; i++){
			System.out.print(i + " ");
		}
		return i;//返回值
	}
}
public class TestMyCallable {
	public static void main(String[] args) throws InterruptedException, ExecutionException{
		MyCallable mc = new MyCallable();
		FutureTask<Integer> ft = new FutureTask<>(mc);//封裝
		Thread thread = new Thread(ft);
		thread.start();
		//返回值通過FutureTask物件的get方法獲得
		System.out.println("列印返回值:"+ft.get());
	}
}

在這裡插入圖片描述

(4)通過執行緒池(如Executor)建立

Executor 管理多個非同步任務的執行,而無需程式設計師顯式地管理執行緒的生命週期。這裡的非同步是指多個任務的執行互不干擾,不需要進行同步操作。Executor框架的內部使用了執行緒池機制,它在java.util.cocurrent 包下,通過該框架來控制執行緒的啟動、執行和關閉,可以簡化併發程式設計的操作。
Executor主要有三種:

  • CachedThreadPool:一個任務建立一個執行緒;
  • FixedThreadPool:所有任務只能使用固定大小的執行緒;
  • SingleThreadExecutor:相當於大小為 1 的 FixedThreadPool。
public class MyExecutor {
	public static void main(String[] args){
		ExecutorService es = Executors.newCachedThreadPool();
		for(int i=0; i<3; i++){//建立3個MyRunnable程序
			es.execute(new MyRunnable());
		}
		es.shutdown();//關閉ExecutorService
	}
}

在這裡插入圖片描述
Executor介面中之定義了一個方法execute(Runnable command),該方法接收一個Runable例項,它用來執行一個任務,任務即一個實現了Runnable介面的類。ExecutorService介面繼承自Executor介面,它提供了更豐富的實現多執行緒的方法,比如,ExecutorService提供了關閉自己的方法,以及可為跟蹤一個或多個非同步任務執行狀況而生成 Future 的方法。 可以呼叫ExecutorService的shutdown()方法來平滑地關閉 ExecutorService,呼叫該方法後,將導致ExecutorService停止接受任何新的任務且等待已經提交的任務執行完成(已經提交的任務會分兩類:一類是已經在執行的,另一類是還沒有開始執行的),當所有已經提交的任務執行完畢後將會關閉ExecutorService。因此我們一般用該介面來實現和管理多執行緒。

ExecutorService的生命週期包括三種狀態:執行、關閉、終止。建立後便進入執行狀態,當呼叫了shutdown()方法時,便進入關閉狀態,此時意味著ExecutorService不再接受新的任務,但它還在執行已經提交了的任務,當素有已經提交了的任務執行完後,便到達終止狀態。如果不呼叫shutdown()方法,ExecutorService會一直處在執行狀態,不斷接收新的任務,執行新的任務,伺服器端一般不需要關閉它,保持一直執行即可。

二、總結

(1)關於建立程序,最好通過實現介面方式,因為java不支援多繼承,繼承了 Thread 類就無法繼承其它類,但是可以實現多個介面;
(2)通過Executor來啟動執行緒比使用Thread的start方法更好,更易管理,效率更好(用執行緒池實現,節約開銷)

三、參考

https://github.com/CyC2018/CS-Notes/blob/master/notes/Java 併發.md