コトルの並列コルーチン

Question

複数のジョブインスタンスを別々のコルーチンから保存することは可能ですか？私は、コルーチンを一度に実行したいとしましょう。コルーチンは無関係で、1つのコルーチンでは実行できませんが、私はそれらを並列に実行します。 Androidでは、onDestroyメソッドでジョブをキャンセルできるようにジョブインスタンスを保存する必要があります。それぞれの仕事をリストに分けて保存するか、何らかのルールを破ることは受け入れられるでしょうか。私はRXに彼らがサブスクリプションを持っていることを知っていますなぜKotlin Coroutinesには同等のものがないのですか？

val jobList = arrayListOf<Job>() 

fun startJob1() { 
    jobList.add(launch { 
     //do some work 
    }) 

fun startJob1() { 
    jobList.add(launch { 
     //do some other unrelated work 
    }) 

override fun onDestroy() { 
    super.onDestroy() 
    cancelAllActiveJobs(jobList) 
} 

このタイプのアーキテクチャはコルーチンにとって意味がありますか？

Answer 1

あなたが起動Jobオブジェクトのリストを保持manullayことができますが、あなたも使用可能です親子ジョブhierarhyを使用することができます起動したジョブのリストを管理して保持するためのボックス。

ので、まず、代わりにジョブのリストを、あなたは親ジョブへの参照を定義します。

val job = Job() 

その後、あなたは新しいコルーチンを出せたびにあなたがそれこの仕事の子作ります：

fun startJob1() { 
    launch(job) { // make it a child 
     //do some work 
    } 
} 

fun startJob1() { 
    launch(job) { // make it a child 
     //do some other unrelated work 
    } 
} 

最後に、オブジェクトを破棄してすべてのジョブをキャンセルする必要がある場合は、親ジョブをキャンセルするだけです。

override fun onDestroy() { 
    super.onDestroy() 
    job.cancel() 
} 

このapporoachの利点は、ジョブのリストが自動的に管理されることです。新しいコルーチンを起動して親ジョブに追加することができ、完了すると自動的に親ジョブから自分自身を削除します。

あなたはガイドの該当するセクションで詳細を読むことができます：私は、それはなんとかですが、それが正しいことを知っているhttps://github.com/Kotlin/kotlinx.coroutines/blob/master/coroutines-guide.md#cancellation-via-explicit-job

Answer 2

これは完全に実行可能で、特別なものもありません。それは、それ自体はあなたが活動状態をループで行うことができ、それが外部からキャンセルされたかどうかを確認しなければならない、仕事は解約することについて

val jobs = List(100_000) { // launch a lot of coroutines and list their jobs 
     launch { 
      delay(1000L) 
      print(".") 
     } 
    } 
jobs.forEach { it.join() } 

：一度100kの雇用を創出し、この単純な例を見てくださいwhile (isActive)を。ここで

はその後キャンセルされ、2つのジョブでの例です：

fun main(args: Array<String>) = runBlocking { 
    val startTime = System.currentTimeMillis() 
    val jobs = arrayListOf<Job>() 
    jobs += launch { 
     var nextPrintTime = startTime 
     var i = 0 
     while (isActive) { // check if still active 
      if (System.currentTimeMillis() >= nextPrintTime) { 
       println("Job1: Sleeping ${i++} ...") 
       nextPrintTime += 500L 
      } 
     } 
    } 

    //another job 
    jobs += launch { 
     while (isActive) { // check if still active 
      if (System.currentTimeMillis() >= 42) { 
       println("Job2: Sleeping 42 ...") 
       delay(500L) 
      } 
     } 
    } 
    delay(1300L) // delay a bit 
    println("main: Cancelling the sleeping job!") 
    jobs.forEach { it.cancelAndJoin() } // cancels the job and waits for its completion 
}