一篇文章揭开芬兰湾的科特林协程的神秘面纱

  

  

芬兰湾的科特林协程提供了一种新的异步执行方式,但直接查看库函数可能会有点混乱,本文中尝试揭开协程的神秘面纱。

  

  

<强>它是什么
  

  

这是别人翻译:协程把异步编程放入库中来简化这类操作。程序逻辑在协程中顺序表述,而底层的库会将其转换为异步操作。库会将相关的用户代码打包成回调,订阅相关事件,调度其执行到不同的线程(甚至不同的机器),而代码依然想顺序执行那么简单。
  

  

我的理解:子任务程协作运行,优雅的处理异步问题解决方案。

  

<强>它能干什么& # 63;
  

  

我在做安卓开发,它能替换掉处理程序,AsyncTask甚至是Rxjava来优雅的解决异步问题。

  

一篇文章揭开芬兰湾的科特林协程的神秘面纱

  

下面让我们从基础开始吧,假设有一个名为发射可以用来启动协程
  

        私人乐趣myHeavyFunction () {   日志。e(“线程运行”,Thread.currentThread () . name)   }   val发射工作={myHeavyFunction ()}      

上面的代码是使用发射一种非常简单的方法,返回工作一个异步执行函数,工作代表一个协程协同程序作业,可以取消或查询它的状态。
  

        覆盖乐趣>   公共娱乐推出(   背景:CoroutineContext=DefaultDispatcher,   开始:CoroutineStart CoroutineStart.DEFAULT,   父:工作# 63;=零,>   @Suppress (PropertyName)   公众实际val DefaultDispatcher: CoroutineDispatcher=CommonPool      对象CommonPool: CoroutineDispatcher ()      

发布是将CoroutineContext作为第一个参数,这个参数值默认为代表一个CommonPool线程池类的DefaultDispatcher,这个线程池类根据当CPU前处理器总数创建一个带有执行人的CoroutineContext。完整代码在这里。

  

发射是一种协程构建器,可以接受一个协程分配器CoroutineDispatcher,分配器实际上负责在单独的线程中运行代码。

  

我们可以轻松创建自己的分配器:
  

        val singleThreadDispatcher=newSingleThreadContext (singleThreadDispatcher)      

newSingleThreadContext由芬兰湾的科特林协同程序库本身提供,用于创建仅在单个线程上运行的上下文。我们可以在此基础上创建自己的函数:
  

        有趣的& lt; T>singleThreadAsync(布洛克:()→T):工作=发射(singleThreadDispatcher) {block.invoke ()}      工作=singleThreadAsync {myHeavyFunction ()}      

下面是运行后的日志

  

E/线程运行:singleThreadDispatcher

  

所以我们用我们自己的线程方案创建了我们自己的简单协程:)

  

让我们看看我们可以通过调度员做更多事情:
  

        对象MyDispatcher: CoroutineDispatcher () {   覆盖有趣调度(背景:CoroutineContext块:Runnable) {   线程{   block.run ()   }   }   }      对象RxDispatcher: CoroutineDispatcher () {   覆盖有趣调度(背景:CoroutineContext块:Runnable) {   Observable.fromCallable {block.run ()}   .subscribeOn (Schedulers.io ())   .subscribe {}      }   }      对象UIDispatcher: CoroutineDispatcher () {   覆盖有趣调度(背景:CoroutineContext块:Runnable) {   处理程序(Looper.getMainLooper ())。{后   block.run ()   }   }   }      

在这里,我们创建了三个不同的分配器程序并重载了派遣方法,我们在每个派遣方法中以不同的方式执行Runnable块,也就是一个简单的线程,这个异步线程是使用RxJava实现,而Android主线程是使用处理完成。

  

如果我们用这些分配器程序执行我们的函数,我们会得到这些日志

  
  

E/运行的线程:线程- 582
  E/线程运行:RxCachedThreadScheduler-1
  E/线程运行:主要

     

这真的显示了协同程序的强大功能,因为协同程序只是语言语法,它们与运行它们的平台无关。不同线程的职责分配只需开发人员使用一组函数就能实现,他可以在Rx线程或主线程上执行他喜欢的协同程序。

  

协同程序就像空的冰淇淋甜筒,你可以选择你想要冰淇淋的填入

。   


  

  

一篇文章揭开芬兰湾的科特林协程的神秘面纱