image

三、协程的启动参数

以下是 launch 的参数列表，runBlocking、async 与 launch 参数列表是差不多的

• context: CoroutineContext = DefaultDispatcher
  • 当前 协程 的上下文，用于在 协程 与 协程 之间参数传递
  • 可以用于声明当前 协程 在哪一个线程中声明，以及当前 协程 被中断后，在哪一个线程中恢复它
  • DefaultDispatcher 就是一个默认的调度器，当前哪个线程在运行，就直接取哪个线程
• start: CoroutineStart = CoroutineStart.DEFAULT
  • 协程 的启动参数，表示已哪种方式启动
  • CoroutineStart.DEFAULT 默认的启动方式，表示当前线程什么时候有空，就什么时候启动
  • 可选参数：LAZY，如果没有手动调用 job 对象的 start() 或 join() 方法的话，那么该 协程 是不会被启动的
  • 可选参数：ATOMIC，将 协程 以一个原子性质的形式的启动，如果声明此参数，则协程是不可以 cancel 的
  • 可选参数：UNDISPATCHED，未定义，通常用于自定义的启动方式，如果未自定义，则与 DEFAULT 启动方式一致。
• parent: Job? = null
  • 表示在当前 协程 闭包的外层的 job，一般情况下使用不到
• block: suspend CoroutineScope.() -> Unit
  • 协程真正要去执行的内容

四、协程的语法糖

允许我们使用同步的代码格式，发起一次异步的网络请求

package zyf.com.kotlin_

import android.os.AsyncTask
import kotlinx.coroutines.experimental.CoroutineDispatcher
import kotlinx.coroutines.experimental.Runnable
import kotlin.coroutines.experimental.CoroutineContext

/**
 * create by zyf on 2018/9/17 下午4:58
 */
object AndroidCommonPool: CoroutineDispatcher(){
    override fun dispatch(context: CoroutineContext, block: Runnable) {
        //使用android官方提供的线程池来执行任务
        AsyncTask.THREAD_POOL_EXECUTOR.execute(block)
    }
}

package zyf.com.kotlin_

import android.widget.TextView
import kotlinx.coroutines.experimental.android.UI
import kotlinx.coroutines.experimental.async
import kotlinx.coroutines.experimental.launch
import kotlinx.coroutines.experimental.runBlocking
import okhttp3.OkHttpClient
import okhttp3.Request

/**
 * create by zyf on 2018/9/17 下午4:46
 */
private val mOkHttpClient= OkHttpClient()
private val mRequest=Request.Builder().url("https://www.baidu.com").get().build()

fun ktGet(textView: TextView) = runBlocking{

    launch(UI) {
        //传入的AndroidCommonPool表示 async 开启的这个协程，允许在 AndroidCommonPool 提供的线程中
        textView.text = async(AndroidCommonPool) {
            mOkHttpClient.newCall(mRequest).execute().body()?.string()
        }.await()
    }


}

package zyf.com.kotlin_

import android.support.v7.app.AppCompatActivity
import android.os.Bundle
import android.view.View
import kotlinx.android.synthetic.main.activity_main.*

class MainActivity : AppCompatActivity() {

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


    }

    fun java(v:View){

    }

    fun kotlin(v:View){
        ktGet(showTv)
    }
}

<?xml version="1.0" encoding="utf-8"?>
<android.support.constraint.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:app="http://schemas.android.com/apk/res-auto"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    tools:context=".MainActivity">

    <ScrollView
        android:layout_width="match_parent"
        android:layout_height="match_parent">

        <LinearLayout
            android:layout_width="match_parent"
            android:layout_height="match_parent"
            android:orientation="vertical">

            <TextView
                android:id="@+id/showTv"
                android:layout_width="wrap_content"
                android:layout_height="wrap_content" />

            <Button
                android:id="@+id/javaBtn"
                android:layout_width="wrap_content"
                android:layout_height="wrap_content"
                android:text="Java获取网络数据"/>

            <Button
                android:id="@+id/kotlinBtn"
                android:layout_width="wrap_content"
                android:layout_height="wrap_content"
                android:text="Kotlin获取网络数据"
                android:onClick="kotlin"/>

            <Button
                android:id="@+id/cleanBtn"
                android:layout_width="wrap_content"
                android:layout_height="wrap_content"
                android:text="清除"/>
        </LinearLayout>
    </ScrollView>

</android.support.constraint.ConstraintLayout>