java学习之路――线程3(线程之间的通信)(一)

2014-11-24 02:57:46 · 作者: · 浏览: 2

线程有四种状态,任何一个线程肯定处于这四种状态中的一种:

1) 产生(New):线程对象已经产生,但尚未被启动,所以无法执行。如通过new产生了一个线程对象后没对它调用start()函数之前。

2) 可执行(Runnable):每个支持多线程的系统都有一个排程器,排程器会从线程池中选择一个线程并启动它。当一个线程处于可执行状态时,表示它可能正处于线程池中等待排排程器启动它;也可能它已正在执行。如执行了一个线程对象的start()方法后,线程就处于可执行状态,但显而易见的是此时线程不一定正在执行中。

3) 死亡(Dead):当一个线程正常结束,它便处于死亡状态。如一个线程的run()函数执行完毕后线程就进入死亡状态。

4) 停滞(Blocked):当一个线程处于停滞状态时,系统排程器就会忽略它,不对它进行排程。当处于停滞状态的线程重新回到可执行状态时,它有可能重新执行。如通过对一个线程调用wait()函数后,线程就进入停滞状态,只有当两次对该线程调用notify或notifyAll后它才能两次回到可执行状态。

线程一旦启动控制起来就会产生许多问题,线程之间的通信就是十分重要的概念。

下面是一个例子:

第一步:建立一个待处理的对象

package com.lcq.ThreadTest;

/*

*

* 类名:MyExample

* 功能:编写测试类,用于实现数字的增加和减少,交替进行

*

* @version 1.0

* @author lcq

*

*/

public class MyExample {

private int number;

//用于数字增加的同步方法

public synchronized void increase(){

while(0 != number){

try {

//条件不满足时将该线程挂起

wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

number++;

System.out.println(number);

//通知另一个线程启动

notify();

}

//用于数字递减的同步方法

public synchronized void decrease(){

while(0 == number){

try {

//条件满足时将该线程挂起

wait();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

number--;

System.out.println(number);

//通知另一个线程启动

notify();

}

}

第二部:建立两个线程类

package com.lcq.ThreadTest;

/*

* 类名:IncreaseThread

* 功能:用于实现数字的增加的线程类

*

* @version 1.0

* @author lcq

*/

public class IncreaseThread extends Thread{

private MyExample me = new MyExample();

//初始化工作

public IncreaseThread(MyExample me){

this.me = me;

}

@Override

public void run() {

for(int i =0; i < 20; i++){

try {

Thread.sleep((long)(Math.random() * 1000));

} catch (InterruptedException e) {

e.printStackTrace();

}

//调用测试对象的增加数字方法

me.increase();

}

}

}

package com.lcq.ThreadTest;

public class DecreaseThread extends Thread{

/*

* 类名:DecreaseThread

* 功能:用于实现数字的减少的线程类

*

* @version 1.0

* @author lcq

*/

private MyExample me = new MyExample();

//初始化工作

public DecreaseThread(MyExample me){

this.me = me;

}

@Override

public void run() {

for(int i =0; i < 20; i++){

try {

Thread.sleep((long)(Math.random() * 1000));

} catch (InterruptedException e) {

e.printStackTrace();

}

//调用测试对象的减少数字方法

me.decrease();

}

}

}

第三部:建立主测试类

package com.lcq.ThreadTest;

/*

* 类名:MainThreadTest

* 功能:主测试类,使用两个线程之间的通信去实现数字的交替更新,打印出来。

*

* @version 1.0

* @author lcq

*/

public class MainThreadTest {

public static void m