频道栏目
首页 > 程序开发 > 软件开发 > Java > 正文
java学习之路——线程3(线程之间的通信)
2011-10-07 14:08:19      个评论      
收藏   我要投稿

 

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

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 main(String[] args) { 

         

        MyExample me = new MyExample(); 

         

        //初始化增加数字的线程对象 

        Thread it1 = new IncreaseThread(me); 

        Thread it2 = new IncreaseThread(me); 

        //初始化减少数字的线程对象 

        Thread dt1 = new DecreaseThread(me); 

        Thread dt2 = new DecreaseThread(me); 

        //分别启动 

        it1.start(); 

        dt1.start(); 

        it2.start(); 

        dt2.start(); 

 

    } 

 

 

运行之后的效果是:

\

 

摘自:找一种安静

点击复制链接 与好友分享!回本站首页
相关TAG标签 线程 之路 之间
上一篇:java 学习之路——线程2(synchronized静态代码块)
下一篇:java学习之路——对象的浅复制和深复制
相关文章
图文推荐
点击排行

关于我们 | 联系我们 | 广告服务 | 投资合作 | 版权申明 | 在线帮助 | 网站地图 | 作品发布 | Vip技术培训 | 举报中心

版权所有: 红黑联盟--致力于做实用的IT技术学习网站