File: UnconfinedTest.kt

package info (click to toggle)
kotlinx-coroutines 1.0.1-2
  • links: PTS, VCS
  • area: main
  • in suites: bookworm, forky, sid, trixie
  • size: 4,628 kB
  • sloc: xml: 418; sh: 322; javascript: 60; makefile: 17; java: 8
file content (113 lines) | stat: -rw-r--r-- 2,265 bytes parent folder | download
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
/*
 * Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
 */

package kotlinx.coroutines

import kotlin.test.*

class UnconfinedTest : TestBase() {

    @Test
    fun testOrder() = runTest {
        expect(1)
        launch(Dispatchers.Unconfined) {
            expect(2)
            launch {
                expect(4)
                launch {
                    expect(6)
                }

                launch {
                    expect(7)
                }
                expect(5)
            }

            expect(3)
        }

        finish(8)
    }

    @Test
    fun testBlockThrows() = runTest {
        expect(1)
        try {
            withContext(Dispatchers.Unconfined) {
                expect(2)
                withContext(Dispatchers.Unconfined + CoroutineName("a")) {
                    expect(3)
                }

                expect(4)
                launch(start = CoroutineStart.ATOMIC) {
                    expect(5)
                }

                throw TestException()
            }
        } catch (e: TestException) {
            finish(6)
        }
    }

    @Test
    fun testEnterMultipleTimes() = runTest {
        launch(Unconfined) {
            expect(1)
        }

        launch(Unconfined) {
            expect(2)
        }

        launch(Unconfined) {
            expect(3)
        }

        finish(4)
    }

    @Test
    fun testYield() = runTest {
        expect(1)
        launch(Dispatchers.Unconfined) {
            expect(2)
            yield()
            launch {
                expect(4)
            }
            expect(3)
            yield()
            expect(5)
        }.join()

        finish(6)
    }

    @Test
    fun testCancellationWihYields() = runTest {
        expect(1)
        GlobalScope.launch(Dispatchers.Unconfined) {
            val job = coroutineContext[Job]!!
            expect(2)
            yield()
            GlobalScope.launch(Dispatchers.Unconfined) {
                expect(4)
                job.cancel()
                expect(5)
            }
            expect(3)

            try {
                yield()
            } finally {
                expect(6)
            }
        }

        finish(7)
    }
}