ThreadBox

class ThreadBox<out T>(val content: T, val lock: ReentrantLock = ReentrantLock())

A threadbox is a simple utility that makes it harder to forget to take a lock before accessing some shared state. Simply define a private class to hold the data that must be grouped under the same lock, and then pass the only instance to the ThreadBox constructor. You can now use the locked method with a lambda to take the lock in a way that ensures it'll be released if there's an exception.

Note that this technique is not infallible: if you capture a reference to the fields in another lambda which then gets stored and invoked later, there may still be unsafe multi-threaded access going on, so watch out for that. This is just a simple guard rail that makes it harder to slip up.

Example:

private class MutableState { var i = 5 }
private val state = ThreadBox(MutableState())

val ii = state.locked { i }

Constructors

Link copied to clipboard
constructor(content: T, lock: ReentrantLock = ReentrantLock())

Properties

Link copied to clipboard
val content: T
Link copied to clipboard

Functions

Link copied to clipboard
inline fun <R> alreadyLocked(body: T.() -> R): R
Link copied to clipboard
Link copied to clipboard
inline fun <R> locked(body: T.() -> R): R