什么是Golang的WaitGroup的Java等价物

发布时间：2020-12-16 09:23:50 所属栏目：大数据来源：网络整理

导读：Golang有一个名为WaitGroup的东西,有点像 Java中的CompletionService或CountDownLatch或Semaphore或后者的某种组合. 我不完全确定如何在Java中实现WaitGroup.我想象一个带有某种Poison消息的自定义CompletionService将是要走的路(因为队列不能说它们什么时候

Golang有一个名为WaitGroup的东西,有点像 Java中的CompletionService或CountDownLatch或Semaphore或后者的某种组合.

我不完全确定如何在Java中实现WaitGroup.我想象一个带有某种Poison消息的自定义CompletionService将是要走的路(因为队列不能说它们什么时候完成)但是也许有更好的并发数据结构/锁定？

编辑我在下面使用Semaphore发布了一个可能的解决方案,我认为它比使用thread.join更类似.

解决方法

WaitGroup具有Add(delta)方法,可以在创建WaitGroup之后调用该方法. CountDownLatch不支持此功能,需要事先指定任务数量.在这种情况下,可以使用JDK7 Phaser：

phaser.register = wg.Add(1)
phaser.arrive = wg.Done
phaser.await = wg.Wait

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!