gistfile1.scala

import java.util.concurrent.ArrayBlockingQueue

class Worker extends Runnable {
  private val queue = new ArrayBlockingQueue[String](10)

  def pushWork(s: String) = queue.put(s)

  def run {
    while(true) {
      for { job <- Option(queue.poll) } yield { println(job) }
    }
  }
}