Scala FutureとThread.sleepの奇妙な振る舞い

Question

私は現在、将来のコンパニオンオブジェクトを拡張するためのコードを書いています。私が実装する一つの機能は、私が

test("A list of Futures return only the first computed value") { 
    val nums = (0 until 10).toList 
    val futures = 
     nums map { n => Future { Thread.sleep(n*1000); n } } 

    val v = Await.result(Future.any(futures), Duration.Inf) 

    assert(v === 0) 
    } 

しかし、私は(n+1)*1000にn*1000に眠っている時間を切り替えた場合、戻り値は1、ない0で、それを自分のコードをテストしてみましたAny

//returns the future that computes the first value computed from the list. If the first one fails, fail. 
def any[T](fs: List[Future[T]]): Future[T] = { 
    val p = Promise[T]() 

    fs foreach { f => { 
    f onComplete { 
     case Success(v) => p trySuccess v 
     case Failure(e) => p tryFailure e 
    } 
    } } 

    p.future 
} 

です正常に動作します（0を返します）。

0でスリープと呼ばれると特別な効果はありますか？

Answer 1

Thread.sleepは、Futureのブロック操作ですが、実行中であることをExecutionContextに通知していないため、使用するExecutionContextの種類とマシンのプロセッサ数によって動作が異なります。 ExecutionContext.globalで期待どおりblockingを追加した場合、あなたのコードは動作します：

nums map { n => Future { blocking { Thread.sleep(n*1000); n } } } 

Answer 2

私は関数名はので、私はあなたがany正しい方法を実装すると思うanyだと思います。 しかし、最初のものが必要ならば、List引数fsから最初の要素を取得し、約束してください。