forked from swiftlang/swift
- Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathconcurrency-actors.swift
73 lines (58 loc) · 1.7 KB
/
concurrency-actors.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
// RUN: %empty-directory(%t)
// RUN: %target-swift-frontend -enable-experimental-feature Embedded -parse-as-library %s -c -o %t/a.o
// RUN: %target-clang %t/a.o -o %t/a.out -L%swift_obj_root/lib/swift/embedded/%target-cpu-apple-macos -lswift_Concurrency -lswift_ConcurrencyDefaultExecutor -dead_strip
// RUN: %target-run %t/a.out | %FileCheck %s
// REQUIRES: executable_test
// REQUIRES: swift_in_compiler
// REQUIRES: optimized_stdlib
// REQUIRES: OS=macosx
// REQUIRES: swift_feature_Embedded
import _Concurrency
actorNumber{
varval:Int
vartask:Task<Void,Never>?
func increment(){
print("did increment")
val +=1
}
func fib(n:Int)->Int{
if n <2{
return n
}
returnfib(n: n-1)+ fib(n: n-2)
}
init()async{
val =0
task =Task.detached(priority:.high){awaitself.increment()}
// do some synchronous work
letans=fib(n:37)
guard ans ==24157817else{
fatalError("miscomputation?")
}
// make sure task didn't modify me!
guard val ==0else{
fatalError("race!")
}
print("finished init()")
}
init(iterations:Int)async{
variter= iterations
repeat{
val = iter
iter -=1
}while iter >0
}
}
@mainstructMain{
staticfunc main()async{
// CHECK: finished init()
// CHECK-NEXT: did increment
letn1=awaitNumber()
await n1.task!.value
letn2=awaitNumber(iterations:1000)
letval=await n2.val
guard val ==1else{
fatalError("wrong val setting")
}
}
}