獲取Java線程返回值的幾種方式

在實際開發過程中，我們有時候會遇到主線程調用子線程，要等待子線程返回的結果來進行下一步動作的業務。

那么怎么獲取子線程返回的值呢，我這里總結了三種方式：

1. 主線程等待。
2. Join方法等待。
3. 實現Callable接口。

　　Entity類

package com.basic.thread;

/**
 * @author zhangxingrui
 * @create 2019-02-17 22:14
 **/
public class Entity {

    private String name;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

 

主線程等待（這個一看代碼便知曉，沒什么問題）

public static void main(String[] args) throws InterruptedException {
        Entity entity = new Entity();
        Thread thread = new Thread(new MyRunnable(entity));
        thread.start();
        // 獲取子線程的返回值：主線程等待法
        while (entity.getName() == null){
            Thread.sleep(1000);
        }
        System.out.println(entity.getName());
    }

 

　　Join方法阻塞當前線程以等待子線程執行完畢

public static void main(String[] args) throws InterruptedException {
        Entity entity = new Entity();
        Thread thread = new Thread(new MyRunnable(entity));
        thread.start();
        // 獲取子線程的返回值：Thread的join方法來阻塞主線程，直到子線程返回
        thread.join();
        System.out.println(entity.getName());
    }

 

　　通過實現Callable接口

　　這里又分為兩種情況，通過FutureTask或線程池。

　　

　　FutureTask

@SuppressWarnings("all")
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        FutureTask futureTask = new FutureTask(new MyCallable());
        Thread thread = new Thread(futureTask);
        thread.start();
        if(!futureTask.isDone())
            System.out.println("task has not finished!");
        System.out.println(futureTask.get());
    }

　　

　　線程池

@SuppressWarnings("all")
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        ExecutorService executorService = Executors.newCachedThreadPool();
        Future future = executorService.submit(new MyCallable());
        if(!future.isDone())
            System.out.println("task has not finished!");
        System.out.println(future.get());
    }