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标记)
原文：https://www.cnblogs.com/scar1et/p/11900641.html