java并发编程--一道经典多线程题的2种解法
问题的描述
启动3个线程打印递增的数字, 线程1先打印1,2,3,4,5, 然后是线程2打印6,7,8,9,10, 然后是线程3打印11,12,13,14,15. 接着再由线程1打印16,17,18,19,20....以此类推, 直到打印到75. 程序的输出结果应该为:
线程1: 1
线程1: 2
线程1: 3
线程1: 4
线程1: 5
线程2: 6
线程2: 7
线程2: 8
线程2: 9
线程2: 10
...
线程3: 71
线程3: 72
线程3: 73
线程3: 74
线程3: 75
解法一: 采用原始的synchronized, wait(), notify(), notifyAll()等方式控制线程.
// n为即将打印的数字
private static int n = 1;
// state=1表示将由线程1打印数字, state=2表示将由线程2打印数字, state=3表示将由线程3打印数字
private static int state = 1;
public static void main(String[] args) {
final NumberPrintDemo pn = new NumberPrintDemo();
new Thread(new Runnable() {
public void run() {
// 3个线程打印75个数字, 单个线程每次打印5个连续数字, 因此每个线程只需执行5次打印任务. 3*5*5=75
for (int i = 0; i < 5; i++) {
// 3个线程都使用pn对象做锁, 以保证每个交替期间只有一个线程在打印
synchronized (pn) {
// 如果state!=1, 说明此时尚未轮到线程1打印, 线程1将调用pn的wait()方法, 直到下次被唤醒
while (state != 1)
try {
pn.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
// 当state=1时, 轮到线程1打印5次数字
for (int j = 0; j < 5; j++) {
// 打印一次后n自增
System.out.println(Thread.currentThread().getName()
+ ": " + n++);
}
System.out.println();
// 线程1打印完成后, 将state赋值为2, 表示接下来将轮到线程2打印
state = 2;
// notifyAll()方法唤醒在pn上wait的线程2和线程3, 同时线程1将退出同步代码块, 释放pn锁.
// 因此3个线程将再次竞争pn锁
// 假如线程1或线程3竞争到资源, 由于state不为1或3, 线程1或线程3将很快再次wait, 释放出刚到手的pn锁.
// 只有线程2可以通过state判定, 所以线程2一定是执行下次打印任务的线程.
// 对于线程2来说, 获得锁的道路也许是曲折的, 但前途一定是光明的.
pn.notifyAll();
}
}
}
}, "线程1").start();
new Thread(new Runnable() {
public void run() {
for (int i = 0; i < 5; i++) {
synchronized (pn) {
while (state != 2)
try {
pn.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
for (int j = 0; j < 5; j++) {
System.out.println(Thread.currentThread().getName()
+ ": " + n++);
}
System.out.println();
state = 3;
pn.notifyAll();
}
}
}
}, "线程2").start();
new Thread(new Runnable() {
public void run() {
for (int i = 0; i < 5; i++) {
synchronized (pn) {
while (state != 3)
try {
pn.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
for (int j = 0; j < 5; j++) {
System.out.println(Thread.currentThread().getName()
+ ": " + n++);
}
System.out.println();
state = 1;
pn.notifyAll();
}
}
}
}, "线程3").start();
}
}
解法二: 采用JDK1.5并发包提供的Lock, Condition等类的相关方法控制线程.
public class NumberPrint implements Runnable {
private int state = 1;
private int n = 1;
// 使用lock做锁
private ReentrantLock lock = new ReentrantLock();
// 获得lock锁的3个分支条件
private Condition c1 = lock.newCondition();
private Condition c2 = lock.newCondition();
private Condition c3 = lock.newCondition();
@Override
public void run() {
new Thread(new Runnable() {
public void run() {
for (int i = 0; i < 5; i++) {
try {
// 线程1获得lock锁后, 其他线程将无法进入需要lock锁的代码块.
// 在lock.lock()和lock.unlock()之间的代码相当于使用了synchronized(lock){}
lock.lock();
while (state != 1)
try {
// 线程1竞争到了lock, 但是发现state不为1, 说明此时还未轮到线程1打印.
// 因此线程1将在c1上wait
// 与解法一不同的是, 三个线程并非在同一个对象上wait, 也不由同一个对象唤醒
c1.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
// 如果线程1竞争到了lock, 也通过了state判定, 将执行打印任务
for (int j = 0; j < 5; j++) {
System.out.println(Thread.currentThread().getName()
+ ": " + n++);
}
System.out.println();
// 打印完成后将state赋值为2, 表示下一次的打印任务将由线程2执行
state = 2;
// 唤醒在c2分支上wait的线程2
c2.signal();
} finally {
// 打印任务执行完成后需要确保锁被释放, 因此将释放锁的代码放在finally中
lock.unlock();
}
}
}
}, "线程1").start();
new Thread(new Runnable() {
public void run() {
for (int i = 0; i < 5; i++) {
try {
lock.lock();
while (state != 2)
try {
c2.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
for (int j = 0; j < 5; j++) {
System.out.println(Thread.currentThread().getName()
+ ": " + n++);
}
System.out.println();
state = 3;
c3.signal();
} finally {
lock.unlock();
}
}
}
}, "线程2").start();
new Thread(new Runnable() {
public void run() {
for (int i = 0; i < 5; i++) {
try {
lock.lock();
while (state != 3)
try {
c3.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
for (int j = 0; j < 5; j++) {
System.out.println(Thread.currentThread().getName()
+ ": " + n++);
}
System.out.println();
state = 1;
c1.signal();
} finally {
lock.unlock();
}
}
}
}, "线程3").start();
}
public static void main(String[] args) {
new NumberPrint().run();
}
}
总结: 对比解法一和解法二, 显然解法二是更好的解决方案. 解法一的问题在于无法进行精确唤醒, 比如线程1执行完打印任务并调用pn.notifyAll()方法后, 3个线程将再次竞争锁, 而不是精确唤醒线程2. 虽然线程2最终将赢得锁, 下一次的打印任务也肯定会由线程2执行, 但是竞争的持续时间是不可预知的, 只能看线程2的人品.
最糟糕的情形可以是: 线程3竞争到了锁, 紧接着wait. 接下来线程1也竞争到了锁, 然后线程1也wait. 此时就再也没有其他线程跟线程2竞争了, 线程2终于艰难的赢得了锁...
留下3个问题供有兴趣的朋友思考:
1. 解法一和解法二中的while (state != xx)是否可以换成if(state != xx), 为什么?
2. 解法一的中的pn.notifyAll()是否可以换成pn.notify(), 为什么?
3. 是否可以用wait(), notify(), notifyAll()等方法完成类似解法二的精确唤醒, 请给出方案或代码.--这个问题我思考了很久, 却没有头绪. 关键的困难在于必须调用pn的wait()方法和notifyAll()方法, 而不能是其他对象的wait()和notifyAll()方法.
java并发编程--一道经典多线程题的2种解法相关推荐
- 19、Java并发编程：线程间协作的两种方式：wait、notify、notifyAll和Condition
Java并发编程:线程间协作的两种方式:wait.notify.notifyAll和Condition 在前面我们将了很多关于同步的问题,然而在现实中,需要线程之间的协作.比如说最经典的生产者-消费者 ...
- Java并发编程: CyclicBarrier让多线程齐步走
以前在<<编写高质量代码-改善Java程序的151个建议>>一书中看到有一节的标题是"CyclicBarrier让多线程齐步走",觉得这标题挺不错的,所以在 ...
- Java并发编程系列18:多线程之生产者和消费者模式_信号灯法(wait/notify通知机制)
1.生产者消费者模式 生产者消费者问题(Producer-consumer problem),也称为有限缓冲问题(Bounded-buffer problem),是一个多线程同步问题的经典案例.该问题 ...
- Java并发编程(03)：多线程并发访问，同步控制
本文源码:GitHub·点这里 || GitEE·点这里 一.并发问题 多线程学习的时候,要面对的第一个复杂问题就是,并发模式下变量的访问,如果不理清楚内在流程和原因,经常会出现这样一个问题:线程处理 ...
- Java并发编程（JUC）
目录 前言 一.Java并发编程(JUC)是什么? 二.Java创建多线程的4种方式 1.继承Thread类 2.实现Runnable接口 3.实现Callable接口 4.线程池 三.sychorn ...
- Java并发编程—线程间协作方式wait()、notify()、notifyAll()和Condition
原文作者:Matrix海 子 原文地址:Java并发编程:线程间协作的两种方式:wait.notify.notifyAll和Condition 目录 一.wait().notify()和notifyA ...
- 【Java并发编程】并发编程大合集
转载请注明出处:http://blog.csdn.net/ns_code/article/details/17539599 为了方便各位网友学习以及方便自己复习之用,将Java并发编程系列内容系列内容 ...
- java并发编程实战（二）
java并发编程中常常会用到两种容器来存放一些数据,这些数据需要保证能在多线程下正常访问.常见的容器分为两类:同步容器和并发容器.在java并发编程实战一书中的第五章也有讲解. 什么是同步容器以及优劣 ...
- 海子Java并发编程学习总结
2019独角兽企业重金招聘Python工程师标准>>> Java并发编程:进程和线程之由来 Java并发编程:如何创建线程? Java并发编程:Thread类的使用 Java并发编程 ...
最新文章
- rstrip,strip,lstrip字符串内置函数
- 好文分享：我是如何在求职中把自己“推销”出去的
- python优先级排序_Python实现优先级队列结构的方法详解
- js，html条码生成
- android 应用搬家 分区,把安装在SD卡的应用存在DATA分区的数据移到SD卡上
- linux ip onboot,linux onboot no
- python中︿是什么意思_Python learning notes-0003-注释、变量、简单类型、运算符,学习,笔记...
- 包工协议书样本_模板工程承包协议书
- 微信小程序——轮播图
- M2M、物联网应用开发的好助手——Wavecom Sierra 无线MODEM（ GSM/GPRS/EDGE MODEM）
- mac打开注册机显示“您没有权限来打开应用程序
- mindspore详解
- 401832-00-4，Thalidomide-O-PEG4-Amine在EDC或HATU存在下与NHS酯基或羧酸反应的合成化合物
- MTK6735 竖屏横用、旋转90度、MTK_LCM_PHYSICAL_ROTATION
- linux引导过程与服务控制
- 【数据分析】搜索和非结构化数据分析值得关注的5大趋势
- Matplotlib画动态散点图：
- 原来，这就是爱情的模样！
- USGS今天开始向全球提供Landsat9下载
- python笑傲江湖_ensp模拟器上玩python编程自动化（入门）