java学习之路——线程3(线程之间的通信)
线程有四种状态,任何一个线程肯定处于这四种状态中的一种:
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() {
&nb
补充:软件开发 , Java ,