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

三个线程a、b、c并发运行,b,c需要a线程的数据怎么实现(semaphore.acquire()方法和permit标记)

时间:2019-11-20 21:48:13      阅读:117      评论:0      收藏:0      [点我收藏+]

标签:ica   定义   控制   bsp   线程锁   tar   str   方法   操作   

public class ThreadCommunication {
    /**
     * 三个线程a、b、c并发运行,b,c需要a线程的数据怎么实现
     *
     * 根据问题的描述,通过三个线程,ThreadA ThreadB ThreadC
     * ThreadA用于初始化数据num,只有num初始化完成之后再让ThreadB和ThreadC获取到初始化的变量num。
     *
     *
     * 分析过程如下:
     * 考虑到线程的不确定性,因此我们不能确保ThreadA就一定先于ThreadB和ThreadC前执行,就算
     * ThreadA先执行了,我们也无法保证ThreadA什么时候才能将变量num初始化完成。因此我们必须让
     * ThreadB和ThreadC去等待ThreadA完成任务后发出的消息
     *
     * 解决两个问题:
     * 1:让ThreadB和ThreadC先执行完
     * 2:ThreadA执行完之后给ThreadB和ThreadC发送消息
     */
    /**
     * 两种解决方案
     * 1、使用纯Java API的Semaphore类来控制线程的等待和释放
     * 2、使用Android提供的消息机制
     */

    //定义一个变量作为数据
    private static int num;

    public static void main(String[] args) {
        Thread threadA = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    //模拟耗时操作之后初始化变量num
                    Thread.sleep(1000);
                    num=1;
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        Thread threadB = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName()+"获取到num的值为:"+num);
            }
        });
        Thread threadC = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName()+"获取到num的值为:"+num);
            }
        });
        //同时开启三个线程
        threadA.start();
        threadB.start();
        threadC.start();
    }
}

 运行结果:

Thread-2获取到num的值为:0
Thread-1获取到num的值为:0

解决方案1:

  

public class ThreadCommunication {
    /**
     * 三个线程a、b、c并发运行,b,c需要a线程的数据怎么实现
public class ThreadCommunication {

    //定义一个变量作为数据
    private static int num;
    /**
     * 定义一个信号量,该类内部维持了多个线程锁,可以阻塞多个线程,释放多个线程
     * 线程的阻塞是和释放是通过permit概念来实现的
     * 线程通过semaphore.acquire()方法获取permit,如果当前线程有permit则分配给该线程
     * 如果没有则阻塞该线程直到semaphore
     * 调用release()方法释放permit
     * 构造函数中参数:permit(允许)个数;
     */
    private static Semaphore semaphore = new Semaphore(0);

    public static void main(String[] args) {
        Thread threadA = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    //模拟耗时操作之后初始化变量num
                    Thread.sleep(1000);
                    num = 1;
                    //初始化参数后释放两个permit
                    semaphore.release(2);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
        Thread threadB = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    //获取permit,如果semaphore没有可用的permit则等待,如果有则消耗一个
                    semaphore.acquire();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName()+"获取到的num的值为:"+num);
            }
        });
        Thread threadC = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    //获取permit,如果semaphore没有可用的permit则等待,如果有则消耗一个
                    semaphore.acquire();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName()+"获取到的num的值为:"+num);
            }
        });
        //同时开启三个线程
        threadA.start();
        threadB.start();
        threadC.start();
    }
}

运行结果:

Thread-1获取到的num的值为:1
Thread-2获取到的num的值为:1

 

三个线程a、b、c并发运行,b,c需要a线程的数据怎么实现(semaphore.acquire()方法和permit标记)

标签:ica   定义   控制   bsp   线程锁   tar   str   方法   操作   

原文地址:https://www.cnblogs.com/scar1et/p/11900641.html

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