SingleBlockingQueue Usage.kt

import java.util.concurrent.atomic.AtomicBoolean
import kotlin.concurrent.thread

fun main(args: Array<String>) {

    val queue = SingleBlockingQueue<Int>()
    val isDone = AtomicBoolean(false)

    thread {
        for (i in 1..100) {
            queue.offer(i)
        }
        isDone.set(true)
    }

    thread {
        while (!isDone.get()) {
            println(queue.take())
            Thread.sleep(100) //retarding the next take() will result in last item getting skipped
        }
    }

    Thread.sleep(10000)

}