concurrency_kills.scala

  def main(args: Array[String]): Unit = {
    import java.util.concurrent._
    import scala.util.Random._
    val executor = Executors.newFixedThreadPool(2)
    for(_ <- 1 to 10000){
      executor.submit(new Runnable(){
        def run = {
          if(nextInt(2) % 2 == 0) Bank.transfer("from", "to", nextInt(50))
          else Bank.transfer("to", "from", nextInt(50))
        }
      })
    }
  }