码迷,mamicode.com
首页 > 编程语言 > 详细

Java多线程基础(四)Java传统线程同步通信技术

时间:2015-11-16 01:01:17      阅读:189      评论:0      收藏:0      [点我收藏+]

标签:java   多线程   线程通信   synchroniz   

Java多线程基础(四)Java传统线程同步通信技术

编写代码实现以下功能

子线程循环10次,接着主线程循环100次,接着又回到子线程循环10次,接着再回到主线程又循环100次,如此循环50次。

分析

1)子线程循环10次与主线程循环100次必须是互斥的执行,不能出现交叉,下面代码中通过synchronized关键字实现此要求;
2)子线程与主线程必须交替出现,可以通过线程同步通信技术实现,下面代码中通过bShouldSub变量实现此要求;

其他需要注意的地方

1)其中business变量必须声明为final类型,因为在匿名内部类和局部内部类中调用的局部变量必须是final的,这样保证:
- 变量的一致性(编译时final变量会被复制一份作为局部内部类的变量);
- 并避免局部变量的生命周期与局部内部类的对象的生命周期不一致。

否则,
- 若该变量被传入局部内部类之后,局部变量在外部类中被修改,则内部类中该变量的值与外部类中不一致,可能导致不可预知的情况发生;
- 或是导致局部变量生命周期随着方法的结束而从栈中清除,局部内部类访问一个已不存在的变量。
若是成员变量,则不需要是final的。

详情可参考以下文章:
http://feiyeguohai.iteye.com/blog/1500108
http://blog.csdn.net/whuslei/article/details/6251020
2)内部类分为成员内部类、静态内部类、局部内部类、匿名内部类四种,四者的生命周期及详细使用方法请自行问谷歌或度娘。

代码实现

package cn.king;

public class TraditionalThreadCommunication {

    public static void main(String[] args) {
        // 必须声明为final
        final Business business = new Business();
        new Thread(
                new Runnable() {

                    @Override
                    public void run() {
                        for(int i=1; i<=50; i++) {
                            business.sub(i);
                        }
                    }

                }
                ).start();

        for(int i=1; i<=50; i++) {
            business.main(i);
        }
    }

}

class Business {
    // 该变量用于线程间通信
    private boolean bShouldSub = true;
    public synchronized void sub(int i) {
        if(!bShouldSub) {
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        for(int j=1; j<=10; j++) {
            System.out.println("sub thread sequence of " 
                                + j + ", loop of " + i);
        }
        bShouldSub = false;
        this.notify();
    }
    public synchronized void main(int i) {
        if(bShouldSub) {
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        for(int j=1; j<=100; j++) {
            System.out.println("main thread sequence of " 
                                + j + ", loop of " + i);
        }
        bShouldSub = true;
        this.notify();
    }
}

版权声明:本文为博主原创文章,未经博主允许不得转载。

Java多线程基础(四)Java传统线程同步通信技术

标签:java   多线程   线程通信   synchroniz   

原文地址:http://blog.csdn.net/kingzone_2008/article/details/49853341

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!