学步园

多线程环境中，比较掌握的事情之一就是如何返回线程的信息。因为run和start方法并不返回任何值。
    假设现在有两个线程，主线程和一个子线程，子线程读文件，主线程需要对文件的结果进行操作，当然，最简单的方法就是读文件和处理读出的文件全部都在主线程中进

行。
   
    线程如何返回信息？ 首先，采用轮询的方法：

import java.io.BufferedReader;<br /> import java.io.File;<br /> import java.io.FileReader;<br /> import java.io.IOError;<br /> import java.io.IOException;<br /> public class MainThread {</p> <p> public static void main(String[] args) throws Exception {<br /> File[] files = new File[5];<br /> ReadFileThread rft = new ReadFileThread(new File("test4.txt"));<br /> rft.start();<br /> //rft.join();<br /> /*需要一个好的方法，来保证 getContent在content准备好之前就调用*/<br /> //System.out.println(rft.getContent());</p> <p> /*采用轮询的方法*/<br /> StringBuffer content = null;<br /> while(true) {<br /> content = rft.getContent();<br /> if(content.length() > 0) {<br /> System.out.println("文件内容为:" + content);<br /> System.out.println("文件内容长度为:"+content.length());<br /> break;<br /> }<br /> }<br /> }</p> <p> /*采用回调的方式，此方法为回调方法， 将会在子线程中调用*/<br /> public static void receiveContent(StringBuffer content) {<br /> System.out.println("文件内容为:" + content);<br /> System.out.println("文件内容长度为:"+content.length());<br /> }</p> <p>}<br /> class ReadFileThread extends Thread {</p> <p> /*File对象引用*/<br /> private File file;</p> <p> /* content成员 */<br /> private StringBuffer content;</p> <p> /*获取文件内容方法*/<br /> public StringBuffer getContent() {<br /> return this.content;<br /> }<br /> /*构造函数初始化*/<br /> public ReadFileThread(File file) {<br /> this.file = file;<br /> this.content = new StringBuffer();<br /> }</p> <p> /*线程run方法，读文件*/<br /> public void run() {<br /> try {<br /> FileReader fr = new FileReader(file);<br /> BufferedReader br = new BufferedReader(fr);<br /> String temp = "";<br /> while( (temp=br.readLine()) != null ) {<br /> content.append(temp);<br /> }<br /> br.close();<br /> fr.close();</p> <p> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }

上面这种轮询的方法，只需要在主线程中不停的调用getContent方法，如果有数据则进行处理，这里的处理仅仅是将数据输出到控制台。这个方案能起到作用，但是在主线程中使

用一个循环来不断询问ReadFileThread类对象的getContent方法，浪费了很多CPU循环。轮询的方法实际上是主线程不断的询问子线程读取是否结束，其实可以反过来，如果子线程

读取数据结束，则通知主线程，这种方法可以称之为回调。修改后的代码：

import java.io.BufferedReader;<br /> import java.io.File;<br /> import java.io.FileReader;<br /> import java.io.IOError;<br /> import java.io.IOException;<br /> public class MainThread {<br /> public static void main(String[] args) throws Exception {<br /> File[] files = new File[5];<br /> ReadFileThread rft = new ReadFileThread(new File("test4.txt"));<br /> rft.start();<br /> }<br /> /*采用回调的方式，此方法为静态方法， 将会在子线程中调用*/<br /> public static void receiveContent(StringBuffer content) {<br /> System.out.println("文件内容为:" + content);<br /> System.out.println("文件内容长度为:"+content.length());<br /> }<br /> }<br /> class ReadFileThread extends Thread {<br /> /*File对象引用*/<br /> private File file;<br /> /* content成员 */<br /> private StringBuffer content;<br /> /*获取文件内容方法*/<br /> public StringBuffer getContent() {<br /> return this.content;<br /> }<br /> /*构造函数初始化*/<br /> public ReadFileThread(File file) {<br /> this.file = file;<br /> this.content = new StringBuffer();<br /> }<br /> /*线程run方法，读文件*/<br /> public void run() {<br /> try {<br /> FileReader fr = new FileReader(file);<br /> BufferedReader br = new BufferedReader(fr);<br /> String temp = "";<br /> while( (temp=br.readLine()) != null ) {<br /> content.append(temp);<br /> }<br /> /*callback MainThread的静态方法*/<br /> MainThread.receiveContent(content);<br /> br.close();<br /> fr.close();<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }

这种回调的方案，实际上是在读取数据完成后调用了主线程类的一个静态方法，这个静态方法最终是在子线程中运行。也可以将主线程类对象传入到子线程中，调用非静态方法来

实现。

还有更复杂的情况 ： 如果有多个对象关心线程的计算结果，那么线程可以保存一个回调对象列表。某个对象可以通过调用Thread或 Runnable类的一个方法，把自己添加到列表中

，表示自己对计算结果有兴趣。如果有多个类的实例对象关心读取结果，可以定义一个接口，所有类都要实现这个接口。此接口将会声明一个回调方法。这种方式其实就是在AWT中

处理事件的方式。 AWT在单独的线程中运行，其它组件通过回调在某个接口中声明的方法来通知事件的发生，比如按钮事件监听器ActionListener。
下面的代码模拟了这种方案:

interface ProcessListener {<br /> public void processResult(StringBuffer content);<br /> }<br />

import java.io.BufferedReader;<br /> import java.io.File;<br /> import java.io.FileReader;<br /> import java.io.IOException;<br /> import java.util.List;<br /> import java.util.ListIterator;<br /> import java.util.Vector;<br /> /**<br /> *<br /> * */<br /> public class ListCallback implements Runnable{<br /> private File file;<br /> private List listListener = new Vector();</p> <p> public ListCallback(File file) {<br /> this.file = file;<br /> }</p> <p> /* 加入到队列中 */<br /> public synchronized void addProcessListener(ProcessListener pl) {<br /> this.listListener.add(pl);<br /> }<br /> /* 从队列中删除 */<br /> public synchronized void removeProcessListener(ProcessListener pl) {<br /> this.listListener.remove(pl);<br /> }</p> <p> /* 遍历集合中的对象，这些对象 */<br /> private synchronized void sendContent(StringBuffer content) {<br /> ListIterator iterator = this.listListener.listIterator();<br /> /* 循环遍历 */<br /> while(iterator.hasNext()) {<br /> ProcessListener pl = (ProcessListener)iterator.next();<br /> /* 调用关注结果数据的对象的处理方法 */<br /> pl.processResult(content);<br /> }<br /> }</p> <p> /* 读取数据 */<br /> public void run() {<br /> try {<br /> FileReader fr = new FileReader(file);<br /> BufferedReader br = new BufferedReader(fr);<br /> String temp = "";<br /> StringBuffer content = new StringBuffer();<br /> while( (temp=br.readLine()) != null ) {<br /> content.append(temp);<br /> }<br /> /*读取成功后，传入sendContent方法中*/<br /> this.sendContent(content);</p> <p> br.close();<br /> fr.close();</p> <p> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }

import java.io.File;<br /> public class UserProcess implements ProcessListener {<br /> private File file;<br /> private StringBuffer content;<br /> public UserProcess(File file) {<br /> this.file = file;<br /> }</p> <p> /*调用此方法创建ListCallback对象，并将当前对象添加到队列中，启动线程*/<br /> public void cal() {<br /> ListCallback lc = new ListCallback(file);<br /> lc.addProcessListener(this);<br /> Thread t = new Thread(lc);<br /> t.start();<br /> }<br /> /*处理结果*/<br /> public void processResult(StringBuffer content) {<br /> this.content = content;<br /> System.out.println(content);<br /> }<br /> public static void main(String[] args) {<br /> /* 在工程目录下定义了四个文件 ，test1.txt, test2.txt, test3.txt, test4.txt*/<br /> for (int i = 1; i <= 4; i++) {<br /> File file = new File("test"+i+".txt");<br /> UserProcess uprocess = new UserProcess(file);<br /> uprocess.cal();<br /> }</p> <p> }<br /> }<br />