Java啟動新線程的幾種方式(Runnable、Callable、CompletableFuture)

来源:https://www.cnblogs.com/Brake/archive/2020/07/06/13256469.html

一、實現Runnable介面 public class RunnableDemo implements Runnable { public void run() { try { Thread.sleep(100); } catch (InterruptedException e) { e.print ...


一、實現Runnable介面

public class RunnableDemo implements Runnable {
    public void run() {
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("in runnable demo");
    }
}

非阻塞調用

    public static void main(String[] args) throws Exception {
        Thread runnableThread = new Thread(new RunnableDemo());
        runnableThread.start();
        System.out.println("in main");
    }

輸出結果

in main
in runnable demo

可以看到線程的運行沒有阻塞當前線程

阻塞調用

    public static void main(String[] args) throws Exception {
        Thread runnableThread = new Thread(new RunnableDemo());
        runnableThread.start();
        runnableThread.join();
        System.out.println("in main");
    }

輸出結果

in runnable demo
in main

Join會阻塞當前線程,一直等待自定義線程才返回。

二、實現Callable介面

在Runnable的例子中,Runnable介面有一個很大的缺陷就是run方法沒有返回值定義,主線程無法獲取到線程執行的結果。這個時候就需要Callable介面。

public class CallableDemo implements Callable<CallableDto> {
    public CallableDto call() throws Exception {
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("in callable demo");
        return new CallableDto(1);
    }
}

class CallableDto {
    private int id;

    public CallableDto(int id) {
        this.id = id;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }
}

非阻塞調用

   public static void main(String[] args) throws Exception {
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(10);
        Future<CallableDto> future = executor.submit(new CallableDemo());
        System.out.println("in main");
    }

輸出結果,如下所示,新啟動的線程沒有阻塞當前線程

in main
in callable demo

阻塞調用,且拿到結果

    public static void main(String[] args) throws Exception {
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(10);
        Future<CallableDto> future = executor.submit(new CallableDemo());
        CallableDto callableDto = future.get();
        System.out.println("in main");
        System.out.println("id from callable is " + callableDto.getId());
    }

get方法首先會阻塞主線程,等待當前線程執行結束才返回,且返回線程的執行結果。

三、CompletableFuture方式

CompletableFuture是jdk1.8引入的api,做了進一步的封裝,用戶線程無需實現Callable介面也能啟動,且能夠返回用戶線程的執行結果

public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor) 

一個沒有實現Callable的普通方法

public class CompletableFutureDemo {
    public CompletableFutureDemoDto action() {
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("in CompletableFutureDemo ");
        return new CompletableFutureDemoDto(1);
    }
}

class CompletableFutureDemoDto {
    private int id;

    public CompletableFutureDemoDto(int id) {
        this.id = id;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }
}

非阻塞調用

    public static void main(String[] args) throws Exception {
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(10);
        CompletableFuture<CompletableFutureDemoDto> future = CompletableFuture.supplyAsync(() ->
        {
            return new CompletableFutureDemo().action();
        }, executor);
        System.out.println("in main");
    }

執行結果,可以看到,主線程沒有被阻塞

in main
in CompletableFutureDemo 

阻塞調用且獲取結果

    public static void main(String[] args) throws Exception {
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(10);
        CompletableFuture<CompletableFutureDemoDto> future = CompletableFuture.supplyAsync(() ->
        {
            return new CompletableFutureDemo().action();
        }, executor);
        CompletableFutureDemoDto demoDto=future.join();
        System.out.println("in main");
        System.out.println("id from demoDto is " + demoDto.getId());
    }

執行結果,主線程一直被阻塞,一直等到用戶線程返回

in CompletableFutureDemo 
in main
id from demoDto is 1

 


您的分享是我們最大的動力!

更多相關文章
  • 1.裝飾器 代碼: import time def timer(func): #timer(test1) def deco(*args,**kwargs): # *args是為了裝飾不同的函數,因為有的函數是需要傳參數,有的不需要 start_time=time.time() res=func(*a ...
  • 1.函數 代碼: def test(x,y): print(x) print(y) test(y=2,x=1)#關鍵字參數 與形參順序無關 test(1,2)#位置參數 與形參一一對應 test(1,y=2)#如果有多個參數,關鍵字參數要放在位置參數後面 View Code 2.進度條 import ...
  • 1.練習 需求:三級菜單,輸入目錄地址進入下一級菜單 代碼: area={ 'hubei':{'huanggang':['qichun','wuxue','huangzhou'], 'wuhan':['wuchang','hankou','hongshan'] }, 'jiangsu':{'nanj ...
  • 通過小程式登錄獲取小程式openID <button hidden="{{is_login}}" class='bottom' type='primary' open-type="getUserInfo" lang="zh_CN" bindgetuserinfo="bindGetUserInfo" ...
  • 公眾號和小程式綁定微信開放平臺 微信開放平臺需要認證(300) 然後進行相關的綁定,綁定時需要相關賬號的原始管理者進行掃碼綁定 小程式也是一樣操作 小程式獲取unionID <button hidden="{{is_login}}" class='bottom' type='primary' ope ...
  • 前言 發年終獎這件事,在互聯網公司正在成為一種傳統,就像不加班都不好意思說是搞互聯網的一樣。 年終獎其實是一件非常有儀式感的事情:年末拿錢回家過年。 今天,和大家看一下那些互聯網行業被大家津津樂道且羡慕嫉妒的年終獎們,同時也期待一下今年的年終獎(嘿嘿嘿 看看阿裡、位元組跳動、華為等這些大廠的年終獎都發 ...
  • 我們一般創建的線程都是普通非守護線程,守護線程是為普通線程服務的。這個說法比較抽象。 具體一個很大的區別是: JVM中所有的線程都是守護線程的時候,JVM就可以退出了--JVM不會等待守護線程是否運行結束 如果還有一個或以上的非守護線程則不會退出 非守護線程例子 public static void ...
  • 一直想深入go語言,下定決心今年要狠抓go語言 | 文章名稱 | 文章鏈接 | | | | | Golang網路編程 | https://www.cnblogs.com/ZhuChangwu/p/13198872.html | | | | | | | ...
一周排行
  • 比如要拆分“呵呵呵90909086676喝喝999”,下麵當type=0返回的是中文字元串“呵呵呵,喝喝”,type=1返回的是數字字元串“90909086676,999”, private string GetStrings(string str,int type=0) { IList<strin ...
  • Swagger一個優秀的Api介面文檔生成工具。Swagger可以可以動態生成Api介面文檔,有效的降低前後端人員關於Api介面的溝通成本,促進項目高效開發。 1、使用NuGet安裝最新的包:Swashbuckle.AspNetCore。 2、編輯項目文件(NetCoreTemplate.Web.c ...
  • 2020 年 7 月 30 日, 由.NET基金會和微軟 將舉辦一個線上和為期一天的活動,包括 微軟 .NET 團隊的演講者以及社區的演講者。本次線上大會 專註.NET框架構建微服務,演講者分享構建和部署雲原生應用程式的最佳實踐、模式、提示和技巧。有關更多信息和隨時瞭解情況:https://focu... ...
  • #abp框架Excel導出——基於vue #1.技術棧 ##1.1 前端採用vue,官方提供 UI套件用的是iview ##1.2 後臺是abp——aspnetboilerplate 即abp v1,https://github.com/aspnetboilerplate/aspnetboilerp ...
  • 前言 本文的文字及圖片來源於網路,僅供學習、交流使用,不具有任何商業用途,版權歸原作者所有,如有問題請及時聯繫我們以作處理。 作者:碧茂大數據 PS:如有需要Python學習資料的小伙伴可以加下方的群去找免費管理員領取 input()輸入 Python提供了 input() 內置函數從標準輸入讀入一 ...
  • 從12年到20年,python以肉眼可見的趨勢超過了java,成為了當今It界人人皆知的編程語言。 python為什麼這麼火? 網路編程語言搜索指數 適合初學者 Python具有語法簡單、語句清晰的特點,這就讓初學者在學習階段可以把精力集中在編程對象和思維方法上。 大佬都在用 Google,YouT ...
  • 在社會上存在一種普遍的對培訓機構的學生一種歧視的現象,具體表現在,比如:當你去公司面試的時候,一旦你說了你是培訓機構出來的,那麼基本上你就涼了,那麼你瞞著不說,然後又通過了面試成功入職,但是以後一旦在公司被髮現有培訓經歷,可能會面臨被降薪,甚至被辭退,培訓機構出來的學生,在用人單位眼裡就是能力低下的 ...
  • from typing import List# 這道題看了大佬寫的代碼,經過自己的理解寫出來了。# 從最外圍的四周找有沒有為O的,如果有的話就進入深搜函數,然後深搜遍歷# 判斷上下左右的位置是否為Oclass Solution: def solve(self, board: List[List[s ...
  • import requests; import re; import os; # 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537.36 (KHTML, li ...
  • import requests; import re; import os; import parsel; 1.請求網頁 header = { "user-agent":'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_5) AppleWebKit/537. ...