可用的Java信号量允许使用ThreadPool
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了可用的Java信号量允许使用ThreadPool，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1680字，纯文字阅读大概需要3分钟。
内容图文
我正在使用教程https://www.baeldung.com/java-semaphore在Java中学习信号量.
教程中的第一个测试(下一个)运行良好.
@Test
public void givenLoginQueue_whenReachLimit_thenBlocked() {
????int slots = 10;
????ExecutorService executorService = Executors.newFixedThreadPool(slots);
????LoginQueueUsingSemaphore loginQueue = new LoginQueueUsingSemaphore(slots);
????IntStream.range(0, slots)
??????.forEach(user -> executorService.execute(loginQueue::tryLogin));
????executorService.shutdown();
?
????assertEquals(0, loginQueue.availableSlots());
????assertFalse(loginQueue.tryLogin());
}
如果我注释executorService.shutdown();在上述测试用例摘要中,则测试失败并显示以下错误.
06001
一旦删除评论并启用executorService.shutdown();测试工作正常.
我不明白测试(信号灯可用许可)如何取决于外部线程池.另外,当我没有释放任何许可证时,如何使用1个插槽？任何简短的解释都会有所帮助.提前致谢.
解决方法:
这是一致的行为,还是有时您获得的Actual值不同(省略executorService.shutdown()调用时)？如果您偶尔看到其他值(例如2或3),则强烈暗示这全是由于调度/定时造成的.
尝试用Thread.sleep(15_000)替换executorService.shutdown().如果进行此更改,测试是否通过？如果是,则表明发生的事情是执行shutdown()调用所需的额外时间足以确保可以派生10个线程并执行其工作(调用tryLogin()来减少信号量) ),然后执行assertEquals()调用.请注意,按照documentation,shutdown()启动ExecutorService的有序关闭,因为它可以使执行任务运行到完成状态,但是在此期间调用本身不会阻塞.结果,执行shutdown()所需的时间恰好足以允许其他线程终止,这似乎完全是偶然的.因此,这不是一个很好的测试,因为该行为在不同的机器上可能会有所不同.相反,测试应该先调用shutdown(),再调用awaitTermination()(或使用由工作程序递减的CountDownLatch以阻止主线程),以确保直到所有工作程序线程终止后才执行assertEquals()调用. .
内容总结
以上是互联网集市为您收集整理的可用的Java信号量允许使用ThreadPool全部内容，希望文章能够帮你解决可用的Java信号量允许使用ThreadPool所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。