https://tttttt.me/kotlin_cn/25220 #kotlin #go 面向job/task计算称 #concurrent ，和完全平行(如滤镜图片)不同

bench=repeat(10_000);o=Any()
c=Channel<Any>()
runBlocking {withContext(Default){
  launch{bench{ c.send(o) }}
  launch{bench{ c.receive() }}
}}
//c.close(); launch.join()

Channel 和调度器 Dispatcher ，在浏览器有 worker.postMessage 和 onmessage

var wg sync.WaitGroup;wg.Add(2)
var token struct{}
c:=make(chan struct{})
go func(){
  defer wg.Done()
  bench{c<-token}
}
go func(){
  defer wg.Done()
  bench{<-c}
}
wg.Wait()

defer WaitGroup 在凑齐2项时传输(循环看错位)？其实是用计数看是否有job存活，都Done掉退出时再继续主线程

runBlocking{//limitedParallelism,newFixedThreadPool,single..
val produce=produce(Default){
  bench{launch{send(1)}}
}
var n=0
produce.consumeEach{n+=it}
}

也有把 Channel 异步序列变得友好的做法

线程切换 >> 函数调用(没有线程切换下的协程切换) > batch之后的函数调用

>分别对应于代码实现的Dispatchers.Default + 无buffer (如果你写对了的话), coroutineScope + 无buffer , coroutineScope + buffer
Exectors singleThread asCoroutineDispatcher
>wait是指blocking的wait么?没看到channel的代码,但是可以断言里面不可能线程停住等待
>不， 是指协程底层在无可调度时的wait；能看到一半是无锁链表，一半是LockSupport.park
之前和他的差这么多，估计是被调度到一个线程上去了，不知道Default里边的策略是什么样的