-
Notifications
You must be signed in to change notification settings - Fork 10.5k
/
Copy pathasync_task_async_let_child_cancel.swift
77 lines (61 loc) · 1.86 KB
/
async_task_async_let_child_cancel.swift
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
// RUN: %target-run-simple-swift(-target %target-swift-5.1-abi-triple -parse-as-library) | %FileCheck %s --dump-input=always
// REQUIRES: executable_test
// REQUIRES: concurrency
// UNSUPPORTED: back_deployment_runtime
// REQUIRES: concurrency_runtime
// REQUIRES: rdar_77671328
@available(SwiftStdlib 5.1, *)
func printWaitPrint(_ int: Int) async -> Int {
print("start, cancelled:\(Task.isCancelled), id:\(int)")
while !Task.isCancelled {
await Task.sleep(100_000)
}
print("done, cancelled:\(Task.isCancelled), id:\(int)")
return int
}
@available(SwiftStdlib 5.1, *)
func test() async {
let h = detach {
await printWaitPrint(0)
}
let handle = detach {
print("detached run, cancelled:\(Task.isCancelled)")
// these tasks will keep spinning until they are cancelled
async let one = printWaitPrint(1)
print("spawned: 1")
async let two = printWaitPrint(2)
print("spawned: 2")
h.cancel()
let first = await one
print("awaited: 1: \(first)")
let second = await two
print("awaited: 2: \(second)")
// is immediately cancelled, since if we got here one and two completed,
// which means we're cancelled and thus children should be as well.
async let three = printWaitPrint(3)
let third = await three
print("exit detach")
}
await h.get()
print("cancel")
handle.cancel()
// CHECK: detached run, cancelled:false
// the 1 and 2 tasks are racing so we don't check the specific IDs for them
// CHECK: start, cancelled:false
// CHECK: start, cancelled:false
// CHECK: cancel
// CHECK: done, cancelled:true
// CHECK: done, cancelled:true
// CHECK: start, cancelled:true, id:3
// CHECK: done, cancelled:true, id:3
// CHECK: exit detach
// CHECK: exit
await handle.get()
print("exit")
}
@available(SwiftStdlib 5.1, *)
@main struct Main {
static func main() async {
await test()
}
}