kotlinx.coroutines

    8热度

    1回答

    Kotlin corutines是有限状态机和一些任务运行器的糖(例如,默认的ForkJoinPool)。 https://github.com/Kotlin/kotlin-coroutines/blob/master/kotlin-coroutines-informal.md#implementation-details 换句话说,java/kotlin运行时中没有运行时协同程序(但可以通过ht

    4热度

    2回答

    从单独的协程中保存多个作业实例是否可以接受?比方说,我想同时运行一对夫妇协程,它们不相关,不能在一个协程中发生,但我希望它们平行运行。在Android中,我应该保存作业实例,以便我可以在onDestroy方法中取消作业。将每项工作分别保存在清单中还是打破某种规则是可以接受的。我知道在RX中他们有订阅为什么Kotlin协同程序中没有相应的功能? val jobList = arrayListOf<J

    3热度

    1回答

    我有一个Job实例的列表,我想在启动后的某个时候取消它。这看起来如下: val jobs = arrayListOf<Job>() //launch and add jobs... jobs.forEach { it.cancelAndJoin() } // cancels the jobs and waits for completion 不幸的是,这里不可能使用方法引用。其原因是:ca

    6热度

    1回答

    我有以下代码: val context = newFixedThreadPoolContext(nThreads = 10, name="myThreadPool") val total = 1_000_000 //can be other number as well val maxLimit = 1_000 return runBlocking { (0..total step

    1热度

    1回答

    Java具有ThreadLocal变量,对于运行并行操作而不踩其他线程或循环分配,例如OpenCV使用videoCapture.retrieve(image),“image”可以是线程变量。 Kotlin是否有任何“协同本地”变量的含义?如果我想以他们的反例为例,但是每个协程都有一个计数器,我该怎么做? for (i in 1..1_000_000) thread(start = tru

    0热度

    1回答

    这个问题可能也适用于其他图书馆为好,但使用卡桑德拉作为一个具体的例子,以尽量保证我问可以回答的问题: 随着科特林,我可以使用Cassandra的异步方法,然后用ListenableFuture集成,或包装它们。我可以使用Cassandra的同步方法,并使用暂停方法和启动/异步方式来封装它们的使用。 我在猜测,更好的技术是使用库的现有异步方法,假设这将更容易避免死锁并更快,但我猜测并且对协程是新的。

    0热度

    1回答

    我正在尝试为听众创建producer。 我的代码看起来像这样 suspend fun foo() = produce{ someEvent.addListener { this.send(it) } } 但我发现了错误Suspension functions can be called only within coroutine这是有道理的。我的问题是。有没有

    3热度

    1回答

    演员可以通过actor.send()或actor.offer()或actor.offer() 发送消息一旦我的演员从其频道收到消息,我想返回响应。我该怎么做呢?我没有看到任何明显的内置方法。

    6热度

    1回答

    某些JVM框架使用ThreadLocal来存储应用程序的调用上下文,如SLF4j MDC,事务管理器,安全管理器等。 但是,Kotlin协同程序是在不同的线程上调度的,所以它如何工作? (现在的问题是由GitHub issue启发)

    44热度

    1回答

    Kotlin协同程序可用于生产,他们的实验状态是什么意思?