the description for this gist

post.scala

class WorkItem(value: String)
class WorkProducer(numItemsToProduce:Int,
                   queue: BoundedTaskQueue,
                   terminationLatch:CountDownLatch) extends Runnable {
  val r = new Random()
  override def run(): Unit = {
    for {_ <- 1 to numItemsToProduce} {
      queue.add(new WorkItem(r.nextString(5)))
    }
    terminationLatch.countDown()
  }
}