the description for this gist

post.scala

class ChessPlayer(moves: Int,
                  rooks: Stream[Rook],
                  terminationLatch: CountDownLatch)
  extends Runnable {

  val lRand = ThreadLocalRandom.current()
  override def run(): Unit = {
    rooks.take(moves).foreach(_.updatePosition((lRand.nextInt, lRand.nextInt)))
    terminationLatch.countDown()
  }
}