gistfile1.scala

class Geocoder {
  val queue = new LinkedBlockingQueue[(String, Promise[Point])]()

  val httpClient = HttpClients.createDefault()

  var stop = false
  new Thread(new Runnable {
    override def run() =
      while (!stop) {
        val (query, promise) = queue.poll()
        val response = httpClient.execute(new HttpGet(s"http://maps.bing.com/blablabla?q=$query&blabla=bla"))
        try {
          println(response)
          promise.success(Point(0.0, 0.0))
        } finally {
          response.close()
        }
      }
  })

  def schedule(query: String) = {
    val promise = Promise[Point]()
    queue.put((query, promise))
    promise.future
  }

  def close() = {
    stop = true
    httpClient.close()
  }
}