通道中出现CoroutineContext错误
是指在使用协程通道时，出现了CoroutineContext相关的错误。CoroutineContext是Kotlin协程中的上下文对象，它包含了协程的调度器以及其他协程上下文元素。这个错误可能由于以下几个原因导致：
- 协程上下文不匹配：在使用协程通道时，发送方和接收方的协程上下文必须匹配。如果它们的协程上下文不同，就会导致CoroutineContext错误。解决办法是确保发送方和接收方的协程上下文相同，可以使用
withContext函数来统一协程上下文。 - 无效的协程调度器：协程通道在传输元素时使用协程调度器来管理执行的线程。如果使用了无效的协程调度器，就会导致CoroutineContext错误。解决办法是使用有效的协程调度器，例如
Dispatchers.Default、Dispatchers.IO等。 - 协程取消：如果在使用协程通道时，其中一个协程被取消了，就会导致CoroutineContext错误。解决办法是在取消协程之前，确保通道已关闭，并在接收方检查协程的取消状态。
通道中出现CoroutineContext错误可能会导致通道无法正常工作，因此需要仔细检查并解决这个问题。腾讯云提供了一系列的云原生解决方案，包括云原生应用引擎TKE、云原生数据库TDSQL、云原生容器引擎CVM等，可以帮助开发者构建高可靠、高性能、弹性伸缩的云原生应用。您可以通过腾讯云官网了解更多相关产品信息和文档：腾讯云云原生解决方案。
相关·内容
我有下面的kotlin协程代码。 import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun main() = runBlocking <Unit> {
val channel = Channel<Int>(4)
val sender = launch (coroutineContext) {
repeat(10) {
println("sending $it")
浏览 12提问于2019-02-08得票数 0
回答已采纳
我有一个简单的生产者和一个消费者使用合作频道。下面是一个简单的版本：
class Producer {
suspend fun start(): ReceiveChannel<String> {
val channel = Channel<String>(Channel.UNLIMITED)
// Asynchronous channel.send(it) from an object callback
channel.invokeOnClose {
// Channel is closed...
}
r
浏览 1提问于2018-11-21得票数 3
1回答
具有协同和改进的单元测试
、、、
我创建了一个使用协同和改造的应用程序，它运行得很好。当我试图为演示者创建UT时，问题就出现了。在这里，我是如何让主持人：
class MainPresenter : ViewModel() {
private val compositeDisposable = CompositeDisposable()
private val heroesRepository: HeroesRepository = heroesRepositoryModel.instance()
private lateinit var listener: ActivityStatesListene
浏览 0提问于2019-01-11得票数 1
1回答
我正试图在后端的gRPC中处理JWT身份验证。我可以在拦截器中提取JWT，但是如何在我的服务中访问它呢？我认为应该用CoroutineContextServerInterceptor来完成，但这不起作用： val jwtKey: Context.Key<String> = Context.key("jwtKey")
fun main() {
ServerBuilder.forPort(8980).intercept(UserInjector).addService(MyService).build().start().awaitTermination()
浏览 16提问于2021-01-23得票数 0
回答已采纳
我正在尝试测试一个将自己声明为CoroutineScope的类。该类在其作用域中有一些launch作业的方法，我必须从测试方法中断言这些作业的效果。
以下是我尝试过的：
import kotlinx.coroutines.*
class Main : CoroutineScope {
override val coroutineContext get() = Job()
var value = 0
fun updateValue() {
this.launch {
delay(1000)
value
浏览 0提问于2018-11-13得票数 1
回答已采纳
2回答
在演示器类中测试协同
、、、、
我很难测试我的演示者，它正在从存储库层调用一个挂起的函数，如下所示：
override fun viewCreated() {
launch {
val hasPermission = permissionChecker.execute() //suspended function
if (hasPermission) {
foo()
} else {
view.bar()
}
}
演示者还扩展了这个
浏览 0提问于2019-07-05得票数 8
回答已采纳
1回答
单元测试作用域视图模型的最佳方法
、、、、
在处理viewModel内部的协同时，最好使用viewModel实现CoroutineScope，这样在清除viewModel时所有协同都会被取消。通常，我看到coroutineContext被定义为Dispatchers.Main + _job，因此在主UI线程中默认执行协同线。通常，这是在一个开放的类上完成的，这样您的所有viewModels都可以扩展它并在没有样板代码的情况下获得范围。
viewModels说，当试图进行单元测试时会出现问题，因为Dispatchers.Main是不可用的，并且试图使用它会引发异常。我试图找到一个好的解决方案，不涉及外部库或太多的锅炉板上的孩子viewMo
浏览 0提问于2018-11-26得票数 1
回答已采纳
2回答
是否可以为当前线程创建一个Dispatcher？请检查此示例代码，作为我想要完成的任务的示例：
val dispatcher = if (parallel) {
Dispatcher.Default
} else {
// What should I write here so I just use the current thread to run doStuff?
}
val deferredList = list.map {
async(dispatcher) { doStuff(it) }
}
浏览 4提问于2021-01-01得票数 2
回答已采纳
我不理解协程构造函数的语法。
private val uiScope = CoroutineScope(Dispatchers.Main + viewModelJob)
我知道参数需要协程上下文类。我不明白的是我们怎么才能添加两个不同的对象呢？Dispatchers.Main类为MainCoroutineDispatcher，viewModelJob类为Job。对此有什么解释吗？
浏览 9提问于2019-07-12得票数 3
回答已采纳
1回答
我有两个Coroutines，我想检查它们是否在同一个上下文/Dispatcher中运行。这是我问题的简化版本，但答案将适用于我正在做的事情：
@Test
fun test() {
val io = runBlocking(Dispatcher.IO) {
coroutineContext
}
val nonIo = runBlocking() {
coroutineContext
}
assertNotEquals(io, nonIo)
}
然而，这是一个糟糕的测试，因为我只是比较两个不同的对象。我想比较一下他们是否使用Dispatc
浏览 3提问于2020-08-12得票数 3
回答已采纳
我需要在各个通道处理器之间插入一个包含10000个元素的缓冲区。
produce()提供了一种配置缓冲区大小的方法：
produce(capacity = 10_000) {
}
但是，filter默认使用map通道：
fun <E, R> ReceiveChannel<E>.map(context: CoroutineContext = Unconfined, transform: suspend (E) -> R): ReceiveChannel<R> =
produce(context) { // No capacity specifie
浏览 2提问于2018-11-13得票数 1
2回答
将通道桥接到序列
、、
此代码基于
val inputProducer = produce<String>(CommonPool) {
(0..inputArray.size).forEach {
send(inputArray[it])
}
}
val resultChannel = Channel<Result>(10)
repeat(threadCount) {
launch(CommonPool) {
inputProducer.consumeEach {
resultChannel.send(getR
浏览 9提问于2017-07-28得票数 7
回答已采纳
1回答
根据the documentation，我们可以使用CoroutineName("theName")命名协程 如果我不使用名称运行它(在单元测试中) runBlocking {
launch {
println("main runBlocking pre : ${Thread.currentThread().name}:${coroutineContext[Job]}")
delay(500)
println(&
浏览 25提问于2020-12-25得票数 5
回答已采纳
2回答
正确地使用协同线
、、、、
我是第一次实施协同机制。我遵循MVP模式为一个简单的登录应用程序。这是我的代码流-
点击的登录按钮将遵循这个方向-
LoginFragment -> LoginPresenter -> Repository -> APIRepository -> RetrofitInterface
登录响应将遵循这个方向-
RetrofitInterface -> APIRepository -> Repository -> LoginPresenter -> LoginFragment
这是密码-
RetrofitInterface.kt
@POST("
浏览 1提问于2019-01-13得票数 7
回答已采纳
1回答
我是否正确取消了协同线？
、、、、
我有自己的观点模型
class StorageValidationViewModel: ViewModel(), CoroutineScope {
//Coroutines
private val _job = SupervisorJob()
override val coroutineContext: CoroutineContext
get() = Dispatchers.Main + _job
override fun onCleared() {
super.onCleared()
coroutineCo
浏览 0提问于2019-05-03得票数 1
我们可以在从像launch这样的构建器函数创建协程时提供一个可选的CoroutineContext，如下所示。 launch(Dispatchers.Unconfined) { // not confined -- will work with main thread
println("Unconfined : I'm working in thread ${Thread.currentThread().name}")
delay(500)
println("Unconfined : After delay in t
浏览 27提问于2019-04-04得票数 1
我的Coroutine运行在主线程上，我在Coroutine上下文中指定了这个线程：
class ClickPreference(context: Context, attrs: AttributeSet) : Preference(context, attrs), CoroutineScope, View.OnClickListener {
override val coroutineContext: CoroutineContext
get() = Dispatchers.Main
override fun onClick(v: View?) {
whe
浏览 0提问于2019-08-26得票数 3
回答已采纳
2回答
在我的视图模型中，我有一个函数，它使用coroutine调用一个API。
fun loadPosts(){
GlobalScope.launch(coroutineContext){
changeState(load = true)
val list= withContext(Dispatchers.IO) {
apiService.getProfile(AUTH)
}
changeState(false,false,null)
showResult(list)
}
}
每
浏览 4提问于2019-11-27得票数 3
回答已采纳
我最近一直在使用kotlin和coroutines，并且我试图在片段类的扩展类中实现一个通道。为了更好地解释我自己：
MapFragment.kt ->片段类，它在单击按钮时调用函数sendFunction()和receiveFunction()。
MapFunctionality.kt ->扩展了MapFragment类。下面是实现的两个函数sendFunction()和receiveFunction()。
MapFragment.kt
open class MapFragment : Fragment(), PermissionsListener, OnMapReadyCall
浏览 2提问于2019-11-23得票数 1
回答已采纳
1回答
这是用于Kotlin的的示例代码：
fun main(args: Array<String>) = runBlocking<Unit> {
val job = Job() // create a job object to manage our lifecycle
// now launch ten coroutines for a demo, each working for a different time
val coroutines = List(10) { i ->
// they are all childre
浏览 4提问于2017-11-29得票数 5
回答已采纳
我正试图通过构建一个由建模的web爬虫来了解更多关于Kotlin协同和通道的信息。
其思想是启动一组协同机制，通过一个链接通道循环访问linksToVisit，并将所有找到的链接推送到另一个通道，foundLinks。
一个单独的for循环然后循环通过foundLinks，检查它们是否已经被访问过，如果没有，则将它们推回linksToVisit，以使协同器能够拾取。
到目前为止，我的代码似乎正确地访问了所有链接，但是没有终止--一旦访问了所有链接，它就会挂起。我做错了什么，是否有可能以这种方式使用for循环？
以下是代码：
fun crawl(startUrl: String) = runBl
浏览 10提问于2022-09-09得票数 2
我正在使用coroutines，并尝试运行以下代码：
private val myScope = CoroutineScope(CoroutineName("my own coroutine"))
fun destroy() {
myScope.cancel()
}
fun main() {
myScope.launch {
println("I'm working in thread ${Thread.currentThread().name}")
}
destroy()
}
令我惊讶的是，我得到的输出
浏览 2提问于2021-08-11得票数 1
我想实现一个DebounceTextWatcher。我打算使用actor在指定的时间间隔内使用文本更改和退出，然后将事件转发给外部使用者。守则如下：
class DebounceTextWatcher(
delayMs: Long = DebounceTextWatcher.DEFAULT_TIMER_DELAY_MS,
handler: (text: String) -> Unit
) : TextWatcher {
private val channel = GlobalScope.actor<String> {
debounce(delayMs).
浏览 0提问于2018-10-10得票数 2
1回答
我有生命周期意识到的协同
abstract class AppViewModel : ViewModel(), CoroutineScope {
private val job = Job()
override val coroutineContext: CoroutineContext
get() = Dispatchers.Main + job
override fun onCleared() {
super.onCleared()
job.cancel()
}
}
如果我在我的视图模型中使用
launch
浏览 3提问于2019-01-12得票数 3
我试图理解协同作用域，并有以下代码：
launch(Dispatchers.Default) { ... }
launch的签名是：
public fun CoroutineScope.launch(
context: CoroutineContext = EmptyCoroutineContext,
start: CoroutineStart = CoroutineStart.DEFAULT,
block: suspend CoroutineScope.() -> Unit
): Job
Dispatchers.Default的类型是：
public abstr
浏览 23提问于2022-01-31得票数 0
在Kotlin中使用withContext时，如何在调用另一个挂起函数后保留新的上下文？
例如：
fun main() = runBlocking {
val anotherBlock = suspend {
assertSame(Dispatchers.IO, coroutineContext[CoroutineDispatcher], "current CoroutineDispatcher should be still Dispatchers.IO")
// Exception in thread "main" j
浏览 4提问于2022-05-17得票数 1
回答已采纳
不确定为什么这是失败的构建。一切似乎都在控制之中。
class MapObjectRepositoryIMPL @Inject constructor(
@ApplicationContext context : Context,
val mapObjectDao: MapObjectDao,
val barrechatNetwork: BarreNetwork,
@DefaultDispatcher private val defaultScope: CoroutineContext
) : MapObjectRepository {
@Module
@Ins
浏览 1提问于2020-11-17得票数 4
1回答
我正在尝试在一个Android应用中使用Kotlin Coroutines，特别是我已经导入了。
Kotlin Coroutine更改Retrofit接口以返回Deferred<T>而不是Call<T>。
我不明白的是如何在我想要的特定CoroutineContext中启动这个Deferred。考虑以下代码：
class MyViewModel @Inject constructor(
private val foo: Foo,
@Named("ui") private val uiContext: Corouti
浏览 0提问于2018-08-10得票数 1
回答已采纳
Ktor中是否有一个线程安全方法，可以静态地访问当前的ApplicationCall？我试图得到以下简单的例子来工作；
object Main {
fun start() {
val server = embeddedServer(Jetty, 8081) {
intercept(ApplicationCallPipeline.Call) {
// START: this will be more dynamic in the future, we don't want to pass Applicati
浏览 4提问于2020-05-16得票数 7
回答已采纳
假设CoroutineScope是由某些生命周期感知组件(如Presenter )实现的。什么时候使用GlobalScope.produce和CoroutineScope.produce比较好；
interface IPresenter, CoroutineScope {
fun state(): ReceiveChannel<Event>
}
class Presenter(
override val coroutineContext: CoroutineContext
): IPresenter, DefaultLifecycleObserver {
fun st
浏览 2提问于2018-11-26得票数 3
回答已采纳
我有一个问题:当我的代码在coroutine (后台服务中)抛出多个异常时，主应用程序在后台服务中执行catch块之前崩溃，但在执行catch块之后。如何解决这个问题?如果抛出1个错误，代码可以正常工作，但如果抛出多个错误，则会崩溃。
期望:在runBlocking中捕捉第一个错误并停止执行，而不让主应用程序崩溃。
错误消息：
E/AndroidRuntime: FATAL EXCEPTION: DefaultDispatcher-worker-8
Process: ..., PID: 9260
RuntimeException: my error
at MyB
浏览 1提问于2020-03-03得票数 1
回答已采纳
例如，此onDetachedFromWindow调用作用域的view.When被取消，但启动的作业仍处于活动状态。 class TestView : FrameLayout,CoroutineScope {
val TAG = "TestView"
override val coroutineContext: CoroutineContext
get() = Dispatchers.Main + Job()
constructor(context: Context) : super(context)
constructor(c
浏览 17提问于2019-09-20得票数 5
回答已采纳
在1.0.0发布后，我正在调查与Android相关的kotlin协同器。
我在创建父作业并在onCleared中清除它的作用域ViewModel (来自arch组件)，或者在onCreate中创建就业机会，在onDestroy中清除作用域活动(与onResume和onPause相同)时，发现了大量的示例。在一些示例中，我遇到了这种代码结构(摘自)：
override val coroutineContext: CoroutineContext
get() = Dispatchers.Main + job
当我们从这个范围开始一个新的协同线时，这个定制的getter是否一直被调用
浏览 0提问于2018-11-06得票数 3
回答已采纳
我正在开发一个Android应用程序，使用MVVM设计模式。
因此，我有一个将flow<T>公开给ViewModel的存储库。然后，ViewModel按照下面的代码使用asLiveData()将flow<T>转换为LiveData<T>。
repository.getFlow().map {
// I will do some long running work here
}.asLiveData()
正如您所看到的，我将在map { }中做一些长期运行的工作。因此，我想在map { }线程中执行Dispatchers.Default中的代码。
根据
浏览 1提问于2021-06-04得票数 2
回答已采纳
2回答
我已经开始为我的MVP项目编写单元测试，但是我依赖协同机制的测试间歇性失败(通过日志记录和调试，我已经确认验证有时会提前发生，当然添加了delay修复)
我尝试过用runBlocking包装，并且从org.jetbrains.kotlinx:kotlinx-coroutines-test中发现了Dispatchers.setMain(mainThreadSurrogate)，但是尝试这么多的组合到目前为止还没有取得任何成功。
abstract class CoroutinePresenter : Presenter, CoroutineScope {
private lateinit
浏览 0提问于2018-12-22得票数 7
回答已采纳
1回答
我已经熟悉了coroutines的ContinuationInterceptor部分，我编写了下面的一节代码来验证我的想法
class MyContext: CoroutineContext.Element{
override val key : CoroutineContext.Key<*>
get() = object : CoroutineContext.Key<MyContext>{}
}
val myInterceptor = object : ContinuationInterceptor {
//Key is set to a n
浏览 4提问于2021-12-29得票数 3
回答已采纳
我有这样的代码：
lifecycleScope.launch(Dispatchers.Default) {
val specialMessage = URL("https://finepointmobile.com/api/inventory/v1/message").readText()
d("Globby", "The message is: $specialMessage")
lastSavedProduct.text = specialMessage /
浏览 27提问于2020-03-12得票数 1
当用户再次联机时，我使用版本2.2.0启动一个Coroutines调用。
，如果我想将CoroutineWorker的线程从默认值(Dispatchers.Default)更改为Dispatchers.IO，则只需重写val coroutineContext，如：
class CoroutineDownloadWorker(context: Context, params: WorkerParameters) : CoroutineWorker(context, params) {
override val coroutineContext = Dispatchers.IO
浏览 2提问于2019-11-20得票数 6
回答已采纳
在Ktor中，我希望实现一些方法来引用coroutineContext中的键值对，而不是在方法参数中拖动对对象的引用。基于https://proandroiddev.com/demystifying-coroutinecontext-1ce5b68407ad，我编写了我的参考类： class MyElement(override val key: CoroutineContext.Key<*>, val value: String) : CoroutineContext.Element
class MyKey: CoroutineContext.Key<MyElement&
浏览 15提问于2020-08-31得票数 0
回答已采纳
我在试着了解科特林的合作机制。我在网上读过几篇文章，包括这篇文章-- --但我仍然对如何访问当前上下文中的协同元素感到有点困惑。这是让我困惑的部分。
使用顶层挂起coroutineContext只读属性可以获得当前上下文中的元素。
println("Running in ${coroutineContext[CoroutineName]}")
在本例中，CoroutineName是对映射到CoroutineName元素的键的引用。我了解到，get方法在coroutineContext上查看提供给它的键的泛型类型--在本例中是CoroutineName --以获得适当的
浏览 0提问于2020-03-16得票数 1
2回答
我正在创建一个库，我正在使用Retrofit和一个调用适配器，它为我提供了一个Deferred<>值。
在我的代码中的一个函数中，我调用launch {}，并在其中try-catch值和可能的异常-为不同的结果调用不同的回调。
我在测试协程上找到的资源都是关于测试挂起的函数，而runBlocking {}是解决所有问题的方案。除了我，它不是
我做了一个简单的例子
@Mock
val mockListener: DoSomething.Listener = mock()
@Test
fun testSomething() {
val doer = DoSomethi
浏览 0提问于2018-08-15得票数 3
带有View的有以下
class WordViewModel(application: Application) : AndroidViewModel(application) {
// ...
private val coroutineContext: CoroutineContext
get() = parentJob + Dispatchers.Main
private val scope = CoroutineScope(coroutineContext)
// ...
}
根据我从答案中了解到的情况，每次都对自定义getter进
浏览 0提问于2019-01-18得票数 3
回答已采纳
我在我的项目中使用以下版本-
implementation "androidx.lifecycle:lifecycle-viewmodel-ktx:2.2.0-alpha04"
implementation "androidx.lifecycle:lifecycle-livedata-ktx:2.2.0-alpha04"
所以在我的View Model类中，我做到了-
fun initView() =
Transformations.map(domain.performOperation()) {
when (it) {
浏览 1提问于2019-09-24得票数 0
我有一个流程： fun startCountingTimer(coroutineContext: CoroutineContext, leftSeconds: Int): Flow<Int> {
return flow {
for (i in leftSeconds downTo 0) {
delay(1000)
emit(i)
}
}
} 我想从一个地方收集它： startWaitingTimer().collect {
...
} 并从另一个位置取消： startWaitingTimer().cancel() 该怎么做
浏览 13提问于2020-09-17得票数 1
我正在尝试使用0.30.0中的最新协同线，并且找出如何使用新的范围范围有困难。在最初的协同机制中，我可以使用UI或CommonPool设置上下文，一切都能正常工作。
现在，在从房间数据库中读取时，我尝试在ViewModel中使用ViewModel，然后将返回的值赋值给我的LiveData对象。
当我试图设置LiveData值时，我得到了以下错误
java.lang.IllegalStateException:不能在后台线程上调用setValue
fun getContact() {
GlobalScope.launch {
val contact
浏览 0提问于2018-09-30得票数 10
回答已采纳
我想从volley中得到结果，然后解析结果来创建一个模型数组列表，以及调用volley请求应该返回arraylist的函数，函数是从其他各种活动调用的，代码是由其他人编写的，所以我需要想出在这个类中实现相同的方法。
这是完整的类代码
class Mock @Inject constructor(private val context: Context) {
val url = Constant.prefix + "get_short_videos.php"
fun loadMockData(): ArrayList<StoriesDataModel&
浏览 2提问于2021-12-05得票数 0
回答已采纳
为什么和何时我们实际上需要在CoroutineScope中实现ViewModel。在ViewModel中，您可以使用viewModelScope，当您想要将Coroutine绑定到ViewModel时，因此当onCleared被调用时，所有运行的协同线都将被自动取消。当您实现CoroutineScope时，您可以直接调用launch，它使用什么范围？我猜它使用的是override val coroutineContext: CoroutineContext提供的。在一个CoroutineScope中实现ViewModel是否意味着您要自己处理coroutine的取消？
浏览 15提问于2022-02-17得票数 1
回答已采纳
1回答
所以我有一个有生命周期的类，包含一个start()和一个stop()函数来启动和停止生命周期。现在，在这个start()函数中，我必须启动一个coroutine，而在stop()中，我必须取消它( start()中的coroutine无限运行，直到它被取消，有点像一个监听消息的套接字)。
因为我希望有一个很好的语法来处理Coroutines，所以我希望这个类实现CoroutineScope。问题是start()和stop()可以被多次调用。
我的问题是，这个实现是否有效并且不包含任何错误。其目的是制作一个可重用的CoroutineScope。
class ReusableCoroutines(
浏览 2提问于2020-10-20得票数 0
回答已采纳
我正在使用Coroutines处理异步作业： viewModelScope.launch {
val userResponse = getUsers() //suspendable function
} 我想要做的是停止所有现有的/正在进行的协程作业。我的想法是点击不同的标签。如果getUsers()耗时长达5秒，并且用户从一个用户选项卡单击到另一个作业选项卡，我希望停止现有的API调用，并且不会观察到响应。 我试着做viewModelScope.cancel()，但似乎不起作用。 问题是-如何在单击按钮时取消现有的作业？
浏览 88提问于2020-09-07得票数 1
回答已采纳
2回答
Java的ThreadLocal变量可以很好地运行并行操作，而无需执行其他线程或每个循环的分配，例如，OpenCV使用videoCapture.retrieve(image)，而“映像”可能是一个线程局部变量。
Kotlin有“协同局部变量”的感觉吗？如果我想以他们的反例为例，但有一个计数器每个协同，我怎么做呢？
for (i in 1..1_000_000)
thread(start = true) {
c.addAndGet(i)
}
浏览 0提问于2017-10-10得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
