iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

CommonPool deprecated

Browse Source
This commit is contained in:
Alfonso Lentini 2018-10-14 10:50:00 +02:00
parent c315ce5975
commit e3b1152c5e
2 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
core-kotlin/src/test/kotlin/com/baeldung/kotlin/CoroutinesUnitTest.kt
View File

@ -60,7 +60,7 @@ class CoroutinesTest {
//when //when
runBlocking { runBlocking {
val promise = launch(CommonPool) { expensiveComputation(res) } val promise = launch(Dispatchers.Default) { expensiveComputation(res) }
res.add("Hello,") res.add("Hello,")
promise.join() promise.join()
} }
@ -84,7 +84,7 @@ class CoroutinesTest {
//when //when
val jobs = List(numberOfCoroutines) { val jobs = List(numberOfCoroutines) {
launch(CommonPool) { launch(Dispatchers.Default) {
delay(1L) delay(1L)
counter.incrementAndGet() counter.incrementAndGet()
} }
@ -100,7 +100,7 @@ class CoroutinesTest {
fun givenCancellableJob_whenRequestForCancel_thenShouldQuit() { fun givenCancellableJob_whenRequestForCancel_thenShouldQuit() {
runBlocking<Unit> { runBlocking<Unit> {
//given //given
val job = launch(CommonPool) { val job = launch(Dispatchers.Default) {
while (isActive) { while (isActive) {
//println("is working") //println("is working")
} }
@ -134,8 +134,8 @@ class CoroutinesTest {
val delay = 1000L val delay = 1000L
val time = measureTimeMillis { val time = measureTimeMillis {
//given //given
val one = async(CommonPool) { someExpensiveComputation(delay) } val one = async(Dispatchers.Default) { someExpensiveComputation(delay) }
val two = async(CommonPool) { someExpensiveComputation(delay) } val two = async(Dispatchers.Default) { someExpensiveComputation(delay) }
//when //when
runBlocking { runBlocking {
@ -155,8 +155,8 @@ class CoroutinesTest {
val delay = 1000L val delay = 1000L
val time = measureTimeMillis { val time = measureTimeMillis {
//given //given
val one = async(CommonPool, CoroutineStart.LAZY) { someExpensiveComputation(delay) } val one = async(Dispatchers.Default, CoroutineStart.LAZY) { someExpensiveComputation(delay) }
val two = async(CommonPool, CoroutineStart.LAZY) { someExpensiveComputation(delay) } val two = async(Dispatchers.Default, CoroutineStart.LAZY) { someExpensiveComputation(delay) }
//when //when
runBlocking { runBlocking {

1
core-kotlin/src/test/kotlin/com/baeldung/thread/CoroutineUnitTest.kt
View File

@ -46,7 +46,6 @@ class CoroutineUnitTest {
return@async "${Thread.currentThread()} has run." return@async "${Thread.currentThread()} has run."
} }
val result = deferred.await() val result = deferred.await()
println(result) println(result)
} }