ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-06-22 17:09:00 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Added comment about use of Semaphore and CountDownLatch

Browse Source
This commit is contained in:
rick.parker
2016-05-24 16:27:39 +01:00
parent 4c75effe8c
commit 7982902e38
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
node/src/main/kotlin/com/r3corda/node/utilities/FiberBox.kt
View File

@ -32,6 +32,9 @@ import kotlin.concurrent.withLock
* to be temporary. In addition, it's enitrely possible to envisage a time when we want public [ProtocolLogic] * to be temporary. In addition, it's enitrely possible to envisage a time when we want public [ProtocolLogic]
* implementations to be able to wait for some condition to become true outside of message send/receive. At that point * implementations to be able to wait for some condition to become true outside of message send/receive. At that point
* we may revisit this implementation and indeed the whole model for this, when we understand that requirement more fully. * we may revisit this implementation and indeed the whole model for this, when we understand that requirement more fully.
*
* TODO: We should consider using a [Semaphore] or [CountDownLatch] here to make it a little easier to understand, but it seems
* as though the current version of Qasar does not support suspending on either of their implementations.
*/ */
class FiberBox<T>(private val content: T, private val lock: Lock = ReentrantLock()) { class FiberBox<T>(private val content: T, private val lock: Lock = ReentrantLock()) {
private var mutated: SettableFuture<Boolean>? = null private var mutated: SettableFuture<Boolean>? = null