当前位置:编程学习 > JAVA >>

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 ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,