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
|
// RUN: %empty-directory(%t)
// RUN: %target-build-swift %import-libdispatch -Xfrontend -disable-availability-checking -enable-actor-data-race-checks -parse-as-library %s -o %t/a.out -module-name main
// RUN: %target-codesign %t/a.out
// NOTE: This test specifically tests the crashing behavior of `checkIsolated`,
// because this behavior is currently disabled
// RUN: env %env-SWIFT_IS_CURRENT_EXECUTOR_LEGACY_MODE_OVERRIDE=crash %target-run %t/a.out
// REQUIRES: executable_test
// REQUIRES: concurrency
// REQUIRES: libdispatch
// rdar://76038845
// REQUIRES: concurrency_runtime
// UNSUPPORTED: back_deployment_runtime
// UNSUPPORTED: single_threaded_concurrency
import StdlibUnittest
import _Concurrency
import Dispatch
// For sleep
#if canImport(Darwin)
import Darwin
#elseif canImport(Glibc)
import Glibc
#elseif canImport(Android)
import Android
#endif
@MainActor func onMainActor() {
print("I'm on the main actor!")
}
func promiseMainThread(_ fn: @escaping @MainActor () -> Void) -> (() -> Void) {
typealias Fn = () -> Void
return unsafeBitCast(fn, to: Fn.self)
}
func launchTask(_ fn: @escaping () -> Void) {
if #available(macOS 10.10, iOS 8.0, watchOS 2.0, tvOS 8.0, *) {
DispatchQueue.global().async {
fn()
}
}
}
func launchFromMainThread() {
launchTask(promiseMainThread(onMainActor))
}
actor MyActor {
var counter = 0
func onMyActor() {
dispatchPrecondition(condition: .notOnQueue(DispatchQueue.main))
counter = counter + 1
}
func getTaskOnMyActor() -> (() -> Void) {
return {
self.onMyActor()
}
}
}
/// These tests now eventually end up calling `dispatch_assert_queue`,
/// after the introduction of checkIsolated in `swift_task_isCurrentExecutorImpl`
@main struct Main {
static func main() {
if #available(SwiftStdlib 5.9, *) {
let tests = TestSuite("data_race_detection")
tests.test("Expect MainActor") {
expectCrashLater()
print("Launching a main-actor task")
launchFromMainThread()
sleep(1)
}
tests.test("Expect same executor") {
expectCrashLater(withMessage: "Incorrect actor executor assumption")
Task.detached {
let actor = MyActor()
let actorFn = await actor.getTaskOnMyActor()
print("Launching an actor-instance task")
launchTask(actorFn)
}
sleep(2)
}
runAllTests()
}
}
}
|
