コトリンコルーチンが嚥下する例外

Question

コルーチンで例外処理がどのように機能するのか非常に混乱します。

私は、同期コードのように例外を渡すサスペンド機能の連鎖を持つことができると考えていました。だからRetrofitがIOExceptionを投げたとすると、プレゼンターなどのサスペンド機能のチェーンの始めにその例外を処理して、ユーザーにエラーを表示することができました。

私はコルーチンを試すためにこの簡単な例を作ったが、例外の実行に失敗した後にthrow Exceptionのコードを呼び出すと例外が発生するが、例外はアプリケーションをクラッシュさせない。

package com.example.myapplication 

import android.os.Bundle 
import android.support.v7.app.AppCompatActivity 
import android.widget.Button 
import android.widget.TextView 
import kotlinx.coroutines.experimental.delay 
import kotlinx.coroutines.experimental.launch 

class MainActivity : AppCompatActivity() { 

    override fun onCreate(savedInstanceState: Bundle?) { 
     super.onCreate(savedInstanceState) 
     setContentView(R.layout.activity_main) 

     val text = findViewById<TextView>(R.id.thing_text) 
     val button = findViewById<Button>(R.id.thing_button) 

     var count = 0 

     button.setOnClickListener { 
      launch { 
       count++ 
//    throw Exception("Boom") 
       val string = delayedStringOfInt(count) 
       runOnUiThread { text.text = string } 
      } 
     } 
    } 

    suspend fun delayedStringOfInt(int: Int): String { 
     delay(1000) 
//  throw Exception("Boom") 
     return int.toString() 
    } 
} 

私はasyncとCoroutineExceptionHandlerを使用して試してみました。

Answer 1

asyncを使用している場合は、結果はどこかにあるawaitになりますので、例外を失うことはありません。

Answer 2

Alexey Romanovの答えに基づいて例外をキャッチするコードを次に示します。もう少し作業を重ねるうちに、私はそれを打ち上げに取り組んでいます。 Log.d("thread", Thread.currentThread().name)を追加すると、遅延がUIをブロックしていないことがわかります。

class MainActivity : AppCompatActivity() { 

    override fun onCreate(savedInstanceState: Bundle?) { 
     super.onCreate(savedInstanceState) 
     setContentView(R.layout.activity_main) 

     val text = findViewById<TextView>(R.id.thing_text) 
     val button = findViewById<Button>(R.id.thing_button) 

     var count = 0 

     button.setOnClickListener { 
      launch { 
       val job = async { 
        count++ 

        val string = delayedStringOfInt(count) 
        updateTextView(text, string) 
       } 

       try { 
        job.await() 
       } catch (e: IOException) { 
        makeToastFromException(e) 
       } 
      } 
     } 
    } 

    fun makeToastFromException(e: Exception) { 
     runOnUiThread { 
      Toast.makeText(this@MainActivity, e.localizedMessage, Toast.LENGTH_SHORT).show() 
     } 
    } 

    fun updateTextView(text: TextView, string: String) { 
     runOnUiThread { text.text = string } 
    } 

    suspend fun delayedStringOfInt(int: Int): String { 
     delay(2000) 
     if (int % 4 == 0) throw IOException("Boom") 
     return int.toString() 
    } 
}