java 多線程 獲取線程返回結果

我們在使用java多線程編寫相關業務代碼時，往往有這樣一種情況，某個線程依賴於其他線程執行結果。

也就是說，我們需要在一個線程中獲取另一個線程的信息。可以分為兩種情況，一種是輪詢，一種是回調，因為輪詢效率很低，所以本文主要介紹回調方法。

回調的主要思想是：線程run方法執行結束時，主動通知main線程，在main線程中做相應處理。通知main線程可以通過調用main方法中的static方法實現。

假定以下場景：

兩個線程讀取兩個不同文件，最后拼接兩個文件內容輸出。

1、以下是線程代碼：

package com.ccg.test;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStreamReader;

public class CallbackThread implements Runnable{

    private String fileName;
    private TestMain callBack;
    
    public CallbackThread(TestMain callBack,String fileName) {
        this.fileName = fileName;
        this.callBack = callBack;
    }

    @Override
    public void run() {
        try {
            File file = new File(fileName);
            InputStreamReader in = new InputStreamReader(new FileInputStream(file),"gbk");
            BufferedReader br = new BufferedReader(in);
            String str = br.readLine(); 
            //通知線程調用者run方法執行結果
            callBack.receiveFileStr(fileName,str);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

可以看到，在run方法結束時回調了線程調用者里面的方法。

2、線程調用者代碼：

package com.ccg.test;

import org.junit.Test;

public class TestMain {

    @Test
    public void test() throws InterruptedException{
        String f1 = "d:\\a.txt";
        String f2 = "d:\\b.txt";
        
        TestMain t1 = new TestMain();
        TestMain t2 = new TestMain();
        
        CallbackThread cb1 = new CallbackThread(t1, f1);
        CallbackThread cb2 = new CallbackThread(t2, f2);
        
        new Thread(cb1).start();
        new Thread(cb2).start();
    }
    
    public void receiveFileStr(String fileName,String readStr){
        StringBuffer sb = new StringBuffer();
        sb.append(fileName + ":" + readStr);
        System.out.println(sb.toString());
    }
}

執行結果如下：

當然這只是最簡單的應用，jdk1.5之后引入了Callable Executor Future的概念使得多線程編寫代碼更優雅，后面會介紹到。