Java多執行緒實現的方式有四種
Java多執行緒實現的方式有四種
1.繼承Thread類,重寫run方法
2.實現Runnable介面,重寫run方法,實現Runnable介面的實現類的例項物件作為Thread建構函式的target
3.通過Callable和FutureTask建立執行緒
4.通過執行緒池建立執行緒
前面兩種可以歸結為一類:無返回值,原因很簡單,通過重寫run方法,run方式的返回值是void,所以沒有辦法返回結果
後面兩種可以歸結成一類:有返回值,通過Callable介面,就要實現call方法,這個方法的返回值是Object,所以返回的結果可以放在Object物件中
方式1:繼承Thread類的執行緒實現方式如下:
public class ThreadDemo01 extends Thread{
public ThreadDemo01(){
//編寫子類的構造方法,可預設
}
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());
}
}
程式結果:
Thread[main,5,main]
我是自定義的執行緒1
執行緒實現方式2:通過實現Runnable介面,實現run方法,介面的實現類的例項作為Thread的target作為引數傳入帶參的Thread建構函式,通過呼叫start()方法啟動執行緒
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()+"–>我是通過實現介面的執行緒實現方式!");
}
}
程式執行結果:
main
Thread-0–>我是通過實現介面的執行緒實現方式!
執行緒實現方式3:通過Callable和FutureTask建立執行緒
a:建立Callable介面的實現類 ,並實現Call方法
b:建立Callable實現類的實現,使用FutureTask類包裝Callable物件,該FutureTask物件封裝了Callable物件的Call方法的返回值
c:使用FutureTask物件作為Thread物件的target建立並啟動執行緒
d:呼叫FutureTask物件的get()來獲取子執行緒執行結束的返回值
public class ThreadDemo03 {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
Callable oneCallable = new Tickets();
FutureTask oneTask = new FutureTask(oneCallable);
Thread t = new Thread(oneTask);
System.out.println(Thread.currentThread().getName());
t.start();
}
}
class Tickets implements Callable{
//重寫call方法
@Override
public Object call() throws Exception {
// TODO Auto-generated method stub
System.out.println(Thread.currentThread().getName()+"–>我是通過實現Callable介面通過FutureTask包裝器來實現的執行緒");
return null;
}
}
程式執行結果:
main
Thread-0–>我是通過實現Callable介面通過FutureTask包裝器來實現的執行緒
執行緒實現方式4:通過執行緒池建立執行緒
public class ThreadDemo05{
private static int POOL_NUM = 10; //執行緒池數量
/**
* @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);
}
//關閉執行緒池
executorService.shutdown();
}
}
class RunnableThread implements Runnable
{
@Override
public void run()
{
System.out.println(“通過執行緒池方式建立的執行緒:” + Thread.currentThread().getName() + " ");
}
}
程式執行結果:
通過執行緒池方式建立的執行緒:pool-1-thread-3
通過執行緒池方式建立的執行緒:pool-1-thread-4
通過執行緒池方式建立的執行緒:pool-1-thread-1
通過執行緒池方式建立的執行緒:pool-1-thread-5
通過執行緒池方式建立的執行緒:pool-1-thread-2
通過執行緒池方式建立的執行緒:pool-1-thread-5
通過執行緒池方式建立的執行緒:pool-1-thread-1
通過執行緒池方式建立的執行緒:pool-1-thread-4
通過執行緒池方式建立的執行緒:pool-1-thread-3
通過執行緒池方式建立的執行緒:pool-1-thread-2
ExecutorService、Callable都是屬於Executor框架。返回結果的執行緒是在JDK1.5中引入的新特徵,還有Future介面也是屬於這個框架,有了這種特徵得到返回值就很方便了。
通過分析可以知道,他同樣也是實現了Callable介面,實現了Call方法,所以有返回值。這也就是正好符合了前面所說的兩種分類
執行Callable任務後,可以獲取一個Future的物件,在該物件上呼叫get就可以獲取到Callable任務返回的Object了。get方法是阻塞的,即:執行緒無返回結果,get方法會一直等待。
再介紹Executors類:提供了一系列工廠方法用於建立執行緒池,返回的執行緒池都實現了ExecutorService介面。
public static ExecutorService newFixedThreadPool(int nThreads)
建立固定數目執行緒的執行緒池。
public static ExecutorService newCachedThreadPool()
建立一個可快取的執行緒池,呼叫execute 將重用以前構造的執行緒(如果執行緒可用)。如果現有執行緒沒有可用的,則建立一個新執行緒並新增到池中。終止並從快取中移除那些已有 60 秒鐘未被使用的執行緒。
public static ExecutorService newSingleThreadExecutor()
建立一個單執行緒化的Executor。
public static ScheduledExecutorService newScheduledThreadPool(int
corePoolSize)
建立一個支援定時及週期性的任務執行的執行緒池,多數情況下可用來替代Timer類。
ExecutoreService提供了submit()方法,傳遞一個Callable,或Runnable,返回Future。如果Executor後臺執行緒池還沒有完成Callable的計算,這呼叫返回Future物件的get()方法,會阻塞直到計算完成。
作者:504的小菜鳥
來源:CSDN
原文:https://blog.csdn.net/u011480603/article/details/75332435
版權宣告:本文為博主原創文章,轉載請附上博文連結!