-
Notifications
You must be signed in to change notification settings - Fork 1.9k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Introduce SupervisorJob & supervisorScope
Fixes #576
- Loading branch information
Showing
7 changed files
with
151 additions
and
15 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,62 @@ | ||
/* | ||
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license. | ||
*/ | ||
|
||
package kotlinx.coroutines.experimental | ||
|
||
import kotlin.coroutines.experimental.* | ||
|
||
/** | ||
* Creates a new _supervisor_ job object in an active state. | ||
* Children of a supervisor job can fail independently of each other. | ||
* | ||
* A failure of a child does not cause the supervisor job to fail and does not affect its other children, | ||
* so a supervisor can implement a custom policy for handling failures of its children: | ||
* | ||
* * A failure of a child job that was created using [launch][CoroutineScope.launch] can be handled via [CoroutineExceptionHandler] in the context. | ||
* * A failure of a child job that was created using [async][CoroutineScope.async] can be handled via [Deferred.await] on the resulting deferred value. | ||
* | ||
* @param parent an optional parent job. If specified, this supervisor job becomes a child job of its parent and | ||
* is cancelled when its parent fails or is cancelled. | ||
*/ | ||
@Suppress("FunctionName") | ||
public fun SupervisorJob(parent: Job? = null) : Job = SupervisorJobImpl(parent) | ||
|
||
/** | ||
* Creates new [CoroutineScope] with [SupervisorJob] and calls the specified suspend block with this scope. | ||
* The provided scope inherits its [coroutineContext][CoroutineScope.coroutineContext] from the outer scope, but overrides | ||
* context's [Job] with [SupervisorJob]. | ||
* | ||
* A failure of a child does not cause this scope to fail and does not affect its other children, | ||
* so a custom policy for handling failures of its children can be implemented. See [SupervisorJob] for details. | ||
*/ | ||
public suspend fun <R> supervisorScope(block: suspend CoroutineScope.() -> R): R { | ||
// todo: optimize implementation to a single allocated object | ||
// todo: fix copy-and-paste with coroutineScope | ||
val owner = SupervisorCoroutine<R>(coroutineContext) | ||
owner.start(CoroutineStart.UNDISPATCHED, owner, block) | ||
owner.join() | ||
if (owner.isCancelled) { | ||
throw owner.getCancellationException().let { it.cause ?: it } | ||
} | ||
val state = owner.state | ||
if (state is CompletedExceptionally) { | ||
throw state.cause | ||
} | ||
@Suppress("UNCHECKED_CAST") | ||
return state as R | ||
|
||
} | ||
|
||
private class SupervisorJobImpl(parent: Job?) : JobSupport(true) { | ||
init { initParentJobInternal(parent) } | ||
override val onFailComplete get() = true | ||
override val handlesException: Boolean get() = false | ||
override fun childFailed(cause: Throwable): Boolean = false | ||
} | ||
|
||
private class SupervisorCoroutine<R>( | ||
parentContext: CoroutineContext | ||
) : AbstractCoroutine<R>(parentContext, true) { | ||
override fun childFailed(cause: Throwable): Boolean = false | ||
} |
58 changes: 58 additions & 0 deletions
58
common/kotlinx-coroutines-core-common/test/SupervisorTest.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,58 @@ | ||
/* | ||
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license. | ||
*/ | ||
|
||
@file:Suppress("NAMED_ARGUMENTS_NOT_ALLOWED") // KT-21913 | ||
|
||
package kotlinx.coroutines.experimental | ||
|
||
import kotlin.test.* | ||
|
||
class SupervisorTest : TestBase() { | ||
@Test | ||
fun testSupervisorJob() = runTest( | ||
unhandled = listOf( | ||
{ it -> it is TestException2 }, | ||
{ it -> it is TestException1 } | ||
) | ||
) { | ||
expect(1) | ||
val supervisor = SupervisorJob() | ||
val job1 = launch(supervisor + CoroutineName("job1")) { | ||
expect(2) | ||
yield() // to second child | ||
expect(4) | ||
throw TestException1() | ||
} | ||
val job2 = launch(supervisor + CoroutineName("job2")) { | ||
expect(3) | ||
throw TestException2() | ||
} | ||
joinAll(job1, job2) | ||
finish(5) | ||
assertTrue(job1.isFailed) | ||
assertTrue(job2.isFailed) | ||
} | ||
|
||
@Test | ||
fun testSupervisorScope() = runTest( | ||
unhandled = listOf( | ||
{ it -> it is TestException1 }, | ||
{ it -> it is TestException2 } | ||
) | ||
) { | ||
val result = supervisorScope { | ||
launch { | ||
throw TestException1() | ||
} | ||
launch { | ||
throw TestException2() | ||
} | ||
"OK" | ||
} | ||
assertEquals("OK", result) | ||
} | ||
|
||
private class TestException1 : Exception() | ||
private class TestException2 : Exception() | ||
} |