4
4
// REQUIRES: concurrency_runtime
5
5
// UNSUPPORTED: back_deployment_runtime
6
6
// UNSUPPORTED: OS=linux-gnu
7
- import Darwin
8
7
9
8
actor Waiter {
10
9
let until : Int
@@ -19,7 +18,6 @@ actor Waiter {
19
18
20
19
func increment( ) {
21
20
self . count += 1
22
- fputs ( " > increment ( \( self . count) / \( self . until) ) \n " , stderr) ;
23
21
if self . until <= self . count {
24
22
if let cc = self . cc {
25
23
cc. resume ( returning: self . count)
@@ -29,12 +27,10 @@ actor Waiter {
29
27
30
28
func wait( ) async -> Int {
31
29
if self . until <= self . count {
32
- fputs ( " > RETURN in Waiter \n " , stderr) ;
33
30
return self . count
34
31
}
35
32
36
33
return await withCheckedContinuation { cc in
37
- fputs ( " > WAIT in Waiter \n " , stderr) ;
38
34
self . cc = cc
39
35
}
40
36
}
@@ -48,9 +44,7 @@ func test_taskGroup_void_neverConsume() async {
48
44
print ( " Start tasks: \( until) " )
49
45
let allTasks = await withDiscardingTaskGroup ( ) { group in
50
46
for n in 1 ... until {
51
- fputs ( " > enqueue: \( n) \n " , stderr) ;
52
47
group. addTask {
53
- fputs ( " > run: \( n) \n " , stderr) ;
54
48
try ? await Task . sleep ( until: . now + . milliseconds( 100 ) , clock: . continuous)
55
49
await waiter. increment ( )
56
50
}
@@ -71,9 +65,7 @@ func test_taskGroup_void_neverConsume(sleepBeforeGroupWaitAll: Duration) async {
71
65
print ( " Start tasks: \( until) " )
72
66
let allTasks = await withDiscardingTaskGroup ( ) { group in
73
67
for n in 1 ... until {
74
- fputs ( " > enqueue: \( n) \n " , stderr) ;
75
68
group. addTask {
76
- fputs ( " > run: \( n) \n " , stderr) ;
77
69
try ? await Task . sleep ( until: . now + . milliseconds( 100 ) , clock: . continuous)
78
70
await waiter. increment ( )
79
71
}
0 commit comments