java多线程获取线程返回结果

 1 package com.ccg.test;
 2 
 3 import java.io.BufferedReader;
 4 import java.io.File;
 5 import java.io.FileInputStream;
 6 import java.io.InputStreamReader;
 7 
 8 public class CallbackThread implements Runnable{
 9 
10     private String fileName;
11     private TestMain callBack;
12     
13     public CallbackThread(TestMain callBack,String fileName) {
14         this.fileName = fileName;
15         this.callBack = callBack;
16     }
17 
18     @Override
19     public void run() {
20         try {
21             File file = new File(fileName);
22             InputStreamReader in = new InputStreamReader(new FileInputStream(file),"gbk");
23             BufferedReader br = new BufferedReader(in);
24             String str = br.readLine(); 
25             //通知线程调用者run方法执行结果
26             callBack.receiveFileStr(fileName,str);
27         } catch (Exception e) {
28             e.printStackTrace();
29         }
30     }
31 }

 1 package com.ccg.test;
 2 
 3 import org.junit.Test;
 4 
 5 public class TestMain {
 6 
 7     @Test
 8     public void test() throws InterruptedException{
 9         String f1 = "d:\\a.txt";
10         String f2 = "d:\\b.txt";
11         
12         TestMain t1 = new TestMain();
13         TestMain t2 = new TestMain();
14         
15         CallbackThread cb1 = new CallbackThread(t1, f1);
16         CallbackThread cb2 = new CallbackThread(t2, f2);
17         
18         new Thread(cb1).start();
19         new Thread(cb2).start();
20     }
21     
22     public void receiveFileStr(String fileName,String readStr){
23         StringBuffer sb = new StringBuffer();
24         sb.append(fileName + ":" + readStr);
25         System.out.println(sb.toString());
26     }
27 }