package throttling

import java.util.Date
import java.util.concurrent.Executors

import scala.concurrent.ExecutionContext

object BlockingQueueThrottler {

  implicit val ec = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(3))

  var counter = 0

  def processImage() = {
    println("requesting " + new Date)
    Thread.sleep(10000)
    println("finishing " + new Date + "\n")
  }

  def main (args: Array[String]) {

    while (counter < 100) {

      ec.execute(new Runnable() {
        override def run() {
          processImage()
        }
      })

      Thread.sleep(100)
      counter = counter + 1
    }
  }
}