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
97
98
99
100
101
102
103
104
105
106
107
108
109
|
// NOT: %target-run-simple-swift( -Xfrontend -disable-availability-checking %import-libdispatch -parse-as-library)
// RUN: %empty-directory(%t)
// RUN: %target-build-swift -Xfrontend -disable-availability-checking %import-libdispatch -parse-as-library %s -o %t/a.out
// RUN: %target-codesign %t/a.out
// RUN: %env-SWIFT_IS_CURRENT_EXECUTOR_LEGACY_MODE_OVERRIDE=legacy %target-run %import-libdispatch %t/a.out
// RUN: %env-SWIFT_IS_CURRENT_EXECUTOR_LEGACY_MODE_OVERRIDE=swift6 %target-run %import-libdispatch %t/a.out
// TODO: Need to find out how to combine %env- and %target-run and %import-libdispatch reliably.
// UNSUPPORTED: OS=linux-gnu
// REQUIRES: concurrency
// REQUIRES: executable_test
// REQUIRES: libdispatch
// rdar://106849189 move-only types should be supported in freestanding mode
// UNSUPPORTED: freestanding
// rdar://119743909 fails in optimized tests.
// UNSUPPORTED: swift_test_mode_optimize
// UNSUPPORTED: swift_test_mode_optimize_size
// UNSUPPORTED: back_deployment_runtime
// REQUIRES: concurrency_runtime
@preconcurrency import Dispatch
@_spi(ConcurrencyExecutors) import _Concurrency
import StdlibUnittest
final class NaiveQueueExecutor: SerialExecutor, CustomStringConvertible {
let name: String
let queue: DispatchQueue
init(name: String, _ queue: DispatchQueue) {
self.name = name
self.queue = queue
}
public func enqueue(_ job: consuming ExecutorJob) {
let unowned = UnownedJob(job)
queue.sync {
unowned.runSynchronously(on: self.asUnownedSerialExecutor())
}
}
public func asUnownedSerialExecutor() -> UnownedSerialExecutor {
let ref = UnownedSerialExecutor(complexEquality: self)
precondition(ref._isComplexEquality, "expected the ref to have complex equality")
return ref
}
public func isSameExclusiveExecutionContext(other: NaiveQueueExecutor) -> Bool {
if Set([self.name, other.name]) == Set(["one", "two"]) {
// those we consider equal
return true
} else {
return false
}
}
var description: Swift.String {
"NaiveQueueExecutor(\(name), \(queue))"
}
}
actor MyActor {
nonisolated let executor: NaiveQueueExecutor
nonisolated var unownedExecutor: UnownedSerialExecutor {
return executor.asUnownedSerialExecutor()
}
init(executor: NaiveQueueExecutor) {
self.executor = executor
}
func test(expectedExecutor: NaiveQueueExecutor) {
expectedExecutor.preconditionIsolated("Expected deep equality to trigger for \(expectedExecutor) and our \(self.executor)")
print("\(Self.self): [\(self.executor.name)] on same context as [\(expectedExecutor.name)]")
}
}
@main
struct Runner {
static func main() async {
let tests = TestSuite("Complex executor equality")
let queue = DispatchQueue(label: "RootQueue")
let one = NaiveQueueExecutor(name: "one", queue)
let two = NaiveQueueExecutor(name: "two", queue)
tests.test("isSameExclusiveContext=true, causes same executor checks to pass") {
let actor = MyActor(executor: one)
await actor.test(expectedExecutor: one)
await actor.test(expectedExecutor: two)
}
tests.test("isSameExclusiveContext=false, causes same executor checks to crash") {
// In Swift6 mode the error message for the crash depends on dispatch, so it is lower
// quality than our specialized messages; We cannot assert on the text since we run in both modes.
expectCrashLater()
let unknown = NaiveQueueExecutor(name: "unknown", DispatchQueue(label: "unknown"))
let actor = MyActor(executor: one)
await actor.test(expectedExecutor: unknown)
}
await runAllTestsAsync()
}
}
|
