多线程编程的一个例子

yxsylyh

关于多线程，理解上不难，做出来真不容易。
 
作业题是这样的：做三个线程（A、B、C），启动后输出启动信息，然后A、B调用wait等待；线程C调用sleep休眠一段时间，然后调用notifyAll，使线程A和线程B继续运行。线程A和线程B恢复运行后输出结束信息后结束，线程C判断线程A和B结束后，C自己也结束。
 
最初做的时候，抛出异常，网上查找，才知道多线程的代码要放到synchronized块里面。OK！照做，可还是出错，没有被唤醒。仔细看多线程说明，是需要一个共同的数据作为等待和唤醒的共享资源。费劲周折，使用Boolean值吧，可还是不唤醒，即使加了static也不行。
 
最后在一篇博文里看到只用布尔值还不行，得用数组，于是把布尔值改为布尔数组，问题最终得到解决。
 
最终代码是这样：
package thread;/** *  * 线程类 *  * 功能： 如果标志 isManager 是 False，则该线程是普通线程（A和B线程），线程开始并输出信息后进入等待状态；<br> * 如果标志 isManager 是 True，则该线程是管理线程（C线程），线程开始、输出信息并休眠一段时间（1秒）后唤醒其它线程。<br> *  * status 是线程唤醒条件，为 false 的话，则普通线程要一直等待下去；<br> * 管理线程设置其值为 true ，并唤醒其它线程。 *  */public class ThreadABC extends Thread {String threadName = "";Boolean isManager = Boolean.FALSE;static Boolean[] status = { false };int time = 1000; // 休眠时长/** * 构造函数 */public ThreadABC() {}/** * 构造函数 *  * @param threadName *            线程名称 * @param isManager *            线程标志（false 为普通线程，true 为管理线程） * @param status *            线程唤醒条件（也许不需要从外部赋值？） */public ThreadABC(String threadName, Boolean isManager, Boolean[] status) {this.threadName = threadName;this.isManager = isManager;this.status = status;}public Boolean[] getStatus() {return status;}public void setStatus(Boolean[] status) {this.status = status;}public void run() {System.out.println(threadName + " 线程已经启动！");// 如果不是管理线程，则进入等待状态if (!isManager) {// 如果满足等待条件（是 false）while (!status[0])synchronized (status) {// synchronized (this) {try {System.out.println(threadName + " 开始等待");status.wait();// this.wait();System.out.println(threadName + " 已被唤醒");} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}} else {// 是管理线程，负责改变条件，并通知其它线程System.out.println(threadName + " 休眠" + time / 1000 + "秒");try {sleep(time);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}// Boolean[] status = { true };// this.setStatus(status);status[0] = true;System.out.println(threadName + " 正在唤醒其它线程");synchronized (status) {// synchronized (this) {status.notifyAll();// this.notifyAll();}}System.out.println(threadName + " 线程结束！");}/** * @param args */public static void main(String[] args) {// TODO Auto-generated method stub// main 函数放到其它的类里也能成功// 不成功的原因是只使用布尔值不行，// 需要把布尔值放到一个数组里就成了Boolean[] status = { false };ThreadABC threadA = new ThreadABC("Thread A", Boolean.FALSE, status);ThreadABC threadB = new ThreadABC("Thread B", Boolean.FALSE, status);ThreadABC threadC = new ThreadABC("Thread C", Boolean.TRUE, status);threadA.start();threadB.start();threadC.start();}}