多线程中Runnable 和Thread关于synchronized的疑…

2019-10-30 16:03:12来源:博客园 阅读 ()

新老客户大回馈,云服务器低至5折

多线程中Runnable 和Thread关于synchronized的疑点

学java时和同学碰到的一道题:

转自https://blog.csdn.net/qq_40857349/article/details/102809100

某公司组织年会,会议入场时有两个入口,在入场时每位员工都能获取一张双色球彩票,假设公司有100个员工,利用多线程模拟年会入场过程,
    并分别统计每个入口入场的人数,以及每个员工拿到的彩票的号码。线程运行后打印格式如下:
    编号为: 2 的员工 从后门 入场! 拿到的双色球彩票号码是: [17, 24, 29, 30, 31, 32, 07]
    编号为: 1 的员工 从后门 入场! 拿到的双色球彩票号码是: [06, 11, 14, 22, 29, 32, 15]
    //.....
    从后门入场的员工总共: 13 位员工
    从前门入场的员工总共: 87 位员工

同学使用继承Thread类来写:

public class ShuangSeQiu extends Thread{
    static int count=1;
    int []arr=new int [7];
    int countHou=0;
    int countQian=0;
    public ShuangSeQiu(String name) {
        super(name);
    }


    @Override
    public synchronized void run() {
//        synchronized (this){
            while(count<101){
                for (int i = 0; i < arr.length; i++) {
                    arr[i]=new Random().nextInt(99);
                }
                if (Thread.currentThread().getName()=="后门"){
                    countHou++;
                }else {
                    countQian++;
                }
                System.out.println("编号为"+(count++)+"的员工从"
                        +Thread.currentThread().getName()
                        +"入场!拿到的双色球彩票号码是:"+ Arrays.toString(arr));
            }
        if (Thread.currentThread().getName()=="后门"){
            System.out.println("从后门入场的员工总共:"+countHou+"位员工");        }
        else {
            System.out.println("从前门入场的员工总共:"+countQian+"位员工");
        }

//        }

    }

}
//测试类

    private static void exe2() {
        ShuangSeQiu houMen=new ShuangSeQiu("后门");
        ShuangSeQiu qianMen=new ShuangSeQiu("前门");
        houMen.start();
        qianMen.start();
    }

我使用实现Runnable接口来写:

public class Lottery implements Runnable {
    List<Integer> list = new ArrayList<>();
    Object lock = new Object();
    int total=1;int frontCount=0;int backCount=0;

    @Override
    public void run() {
        while(total<100){
            synchronized (lock){
            for(int i=0;i<6;i++){
                list.add(new Random().nextInt(100));
            }
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if(Thread.currentThread().getName()=="前门"){
                frontCount++;
            }else {
                backCount++;
            }
            System.out.println("编号为:"+(total++)+"的员工从"+Thread.currentThread().getName()+"入场!拿到的双色球彩票号码是:"+list);
            list.clear();
        }
        }
        if(Thread.currentThread().getName()=="前门"){
            System.out.println("从前门入场的员工总共:"+frontCount+"位员工");
        }else {
            System.out.println("从后门入场的员工总共:"+backCount+"位员工");
        }
    }
}
//测试类
public class Test {
    public static void main(String[] args) {
        Lottery lot=new Lottery();
        Thread Entry1 = new Thread(lot,"前门");
        Thread Entry2 = new Thread(lot,"后门");
        Entry1.start();
        Entry2.start();

    }
}

如果在使用Runnbale实现时,synchronized放在while里程序按预期结果运行,但把synchronized放在run上会出现全部走前门或全部走后门的情况

在和同学讨论后,初步得出结论:

使用接口实现时,是对同一个Lottery()对象操作的,所以两个线程是并发进行,因此在run上使用synchronized时,会锁定先执行的线程,直到他执行完才进入下一个线程,因此会出现全走前门或全走后门。

使用继承类实现时,是对两个对象进行操作,所以两个线程是并行进行的,由于员工数量count是static静态变量,只有一个,所以不会出现重复的员工,但是有时会出现101人的情况(题目是100人),是因为当其中一个线程执行完是99后恰好两个线程同时再次运行,两个都进行了count++,就变成了101个人。

 


原文链接:https://www.cnblogs.com/dev2ce/p/11767928.html
如有疑问请与原作者联系

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有

上一篇:Java和SQL取两个字符间的值

下一篇:如何用IDEA创建springboot(maven)并且整合mybatis连接mysql数