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
|
// RUN: %target-run-simple-swift(-parse-as-library -Xfrontend -disable-availability-checking %import-libdispatch) | %FileCheck %s
// REQUIRES: executable_test
// REQUIRES: concurrency
// REQUIRES: libdispatch
// REQUIRES: rdar78576626
// rdar://76038845
// REQUIRES: concurrency_runtime
// UNSUPPORTED: back_deployment_runtime
// for sleep
#if canImport(Darwin)
import Darwin
#elseif canImport(Glibc)
import Glibc
#elseif canImport(Android)
import Android
#endif
@available(SwiftStdlib 5.1, *)
class Runner {
func run() async {
while !Task.isCancelled {
sleep(1)
}
}
}
@available(SwiftStdlib 5.1, *)
actor Container {
var generation = 0
var runners = [Int : Task<Void, Never>]()
func build(_ n: Int) {
for _ in 0..<n {
let id = generation
generation += 1
let t = detach { [weak self] in
let r = Runner()
await r.run()
await self?.remove(id)
}
runners[id] = t
}
}
func cancelAll() {
var count = 0
for (_, v) in runners {
v.cancel()
count += 1
}
print("Cancelled \(count) runners.")
}
deinit {
print("deinit Container with \(runners.count) runners")
}
func remove(_ id: Int) {
runners.removeValue(forKey: id)
}
}
// CHECK: starting
// CHECK: Cancelled 5 runners.
// FIXME: this doesn't work until we have https://github.com/apple/swift/pull/36298
// COM: deinit Container with {{[0-9]+}} runners
@available(SwiftStdlib 5.1, *)
@main struct RunIt {
static func startTest() async {
let c = Container()
await c.build(5)
sleep(5)
await c.cancelAll()
}
@available(SwiftStdlib 5.1, *)
static func main() async {
print("starting")
await RunIt.startTest()
sleep(5)
}
}
|
