- 43
- 0
三线程顺序输出从1-100
一个主类,函数内部创建三个线程。
相关代码
package concurrent.order.threeThread;
import org.apache.log4j.Logger;
import org.junit.jupiter.api.Test;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Main {
private static Logger log = Logger.getLogger(Main.class);
@Test
void main() {
final Three[] flag = {Three.ONE};
Lock lock = new ReentrantLock();
final Condition oneCondition = lock.newCondition();
final Condition twoCondition = lock.newCondition();
final Condition threeCondition = lock.newCondition();
AtomicInteger integer = new AtomicInteger();
integer.getAndIncrement();
Thread thread1 = new Thread(() -> {
for (; integer.get() < 100; ) {
lock.lock();
while (flag[0] != Three.ONE) {
try {
oneCondition.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
log.info(integer.getAndIncrement());
flag[0] = Three.TWO;
twoCondition.signal();
lock.unlock();
}
});
Thread thread2 = new Thread(() -> {
for (; integer.get() < 100; ) {
lock.lock();
while (flag[0] != Three.TWO) {
try {
twoCondition.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
log.info(integer.getAndIncrement());
flag[0] = Three.THREE;
threeCondition.signal();
lock.unlock();
}
});
Thread thread3 = new Thread(() -> {
for (; integer.get() < 100; ) {
lock.lock();
while (flag[0] != Three.THREE) {
try {
threeCondition.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
log.info(integer.getAndIncrement());
flag[0] = Three.ONE;
oneCondition.signal();
lock.unlock();
}
});
thread1.start();
thread2.start();
thread3.start();
}
}
package concurrent.order.threeThread;
public enum Three {
ONE, TWO, THREE
}
结果是正确输出的,但是我想在每个log输出后sleep一段时间
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
但是问题出现了,只是执行了一次thread1 程序即退出了。
请教各位大神,这个是怎么回事呢?
0
打赏
收藏
点击回答
您的回答被采纳后将获得:提问者悬赏的 10 元积分
网站公告
- 扫一扫访问手机版
回答动态

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器更新之后。服务器里面有部分玩家要重新创建角色是怎么回事啊?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题函数计算不同地域的是不能用内网吧?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题ARMS可以创建多个应用嘛?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题在ARMS如何申请加入公测呀?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题前端小程序接入这个arms具体是如何接入监控的,这个init方法在哪里进行添加?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器刚到期,是不是就不能再导出存档了呢?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器的游戏版本不兼容 尝试更新怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器服务器升级以后 就链接不上了,怎么办?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器转移以后服务器进不去了,怎么解决?预计能赚取 0积分收益

- 神奇的四哥:发布了悬赏问题阿里云幻兽帕鲁服务器修改参数后游戏进入不了,是什么情况?预计能赚取 0积分收益
- 回到顶部
- 回到顶部
