package com.example.kotlin_demo
import androidx.appcompat.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import android.widget.ImageView
import android.widget.TextView
import android.widget.Toast
import androidx.lifecycle.Observer
import com.bumptech.glide.Glide
import kotlinx.coroutines.*
import network.LoadState
import kotlinx.android.synthetic.main.activity_main.* //引用xml 控件id作为变量，避免findviewbyid操作
import java.util.concurrent.Flow
/**
* suspend 修饰的函数 挂起函数，挂起函数只能在挂起函数或携程中运行。函数挂起挂起的是携程，而不是携程所在的线程，挂起后携程和携程所在线程脱钩，挂起结束后回复携程继续执行。
*
* 切换线程：withContext 还有其他方法可以切换
*/
/**
* 修饰符
* ? 可为空，线程安全性，如果为空不执行该表达式
* !!为空则抛异常
*
*/
class MainActivity : AppCompatActivity() {
var img1:ImageView? = null
var img2:ImageView? = null
var img3:ImageView? = null
private lateinit var mainViewModel : MainModelAndView
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
var tv:TextView = findViewById(R.id.tv)
var tv2:TextView = findViewById(R.id.tv2)
var tv3:TextView = findViewById(R.id.tv3)
var tv4:TextView = findViewById(R.id.tv4)
img1 = findViewById(R.id.imageView1)
img2 = findViewById(R.id.imageView2)
img3 = findViewById(R.id.imageView3)
/**
* 打印结果：
* 当前线程start：main
* 切换后：DefaultDispatcher-worker-3
* 切换后end：main
*/
GlobalScope.launch(context = Dispatchers.Main,start = CoroutineStart.DEFAULT) {
System.out.println("当前线程start："+ Thread.currentThread().name)
myMethod()
System.out.println("切换后end："+ Thread.currentThread().name)
}
tv.setOnClickListener {
GlobalScope.launch(context = Dispatchers.Main,start = CoroutineStart.DEFAULT) {
System.out.println("----1----")
delay(2000)
System.out.println("----2----")
delay(2000)
System.out.println("----3----")
}
}
/**
* test1,test2,test3并发执行 所有执行结果出来再相加
*/
tv2.setOnClickListener {
GlobalScope.launch(context = Dispatchers.Default){
val value1 = async { test1() }
val value2 = async { test2() }
val value3 = async { test3() }
all(value1.await(),value2.await(),value3.await())
}
}
/**
* est4,test5，test1并发， test4,test5依赖test1的结果
*/
var job:Job? =null
tv3.setOnClickListener {
job = GlobalScope.launch(context = Dispatchers.Default){
val value1 = async { test1() }
val value2 = async { test4(value1.await()) }
val value3 = async { test5(value1.await()) }
all2(value2.await(),value3.await())
}
}
/**
* 结束携程
*/
tv4.setOnClickListener {
if (job?.isActive!!){
job?.cancel()
Log.d("携程","取消")
}else{
Log.d("携程","已经结束")
}
}
mainViewModel.loadState.observe(this, Observer {
when (it){
is LoadState.Success-> button?.isEnabled = true
is LoadState.Loading->button?.isEnabled = false
is LoadState.Fail->{
button?.isEnabled = true
Toast.makeText(this,"加载失败",Toast.LENGTH_SHORT).show()
}
}
})
mainViewModel.imageData.observe(this, Observer {
Glide.with(this).load(it[0])
Glide.with(this).load(it[1])
Glide.with(this).load(it[2])
})
button.setOnClickListener {
mainViewModel.getData()
}
canelTv6.setOnClickListener {
}
}
/**
* 线程切换
*/
suspend fun myMethod() {
withContext(context = Dispatchers.Default){
System.out.println("切换后："+ Thread.currentThread().name)
}
}
suspend fun test1():Int{
delay(1000)
System.out.println("-----执行test1-----")
return 1
}
suspend fun test2():Int{
delay(2000)
System.out.println("-----执行test2-----")
return 2
}
suspend fun test3():Int{
delay(1500)
System.out.println("-----执行test3-----")
return 3
}
fun all(value1:Int,value2:Int,value3:Int){
System.out.println("结果："+ (value1+value2+value3))
}
suspend fun test4(num:Int):Int{
delay(1500)
System.out.println("-----执行test4-----")
return num
}
suspend fun test5(num:Int):Int{
delay(2000)
System.out.println("-----执行test5-----")
return num
}
fun all2(value1:Int,value2:Int){
System.out.println("结果2："+ (value1+value2))
}
}
