cleanup

Author: ktoso

stdlib/public/Concurrency/CMakeLists.txt

@@ -107,7 +107,7 @@ add_swift_target_library(swift_Concurrency ${SWIFT_STDLIB_LIBRARY_BUILD_TYPES} I
   UncheckedContinuation.swift
   GlobalActor.swift
   MainActor.swift
-  Job.swift
+  PartialAsyncTask.swift
   SourceCompatibilityShims.swift
   Task.cpp
   Task.swift

stdlib/public/Concurrency/PartialAsyncTask.swift

@@ -56,8 +56,13 @@ public struct UnownedJob: Sendable {
   public func _runSynchronously(on executor: UnownedSerialExecutor) {
       _swiftJobRun(self, executor)
   }
-}
 
+  @_alwaysEmitIntoClient
+  @inlinable
+  public func runSynchronously(on executor: UnownedSerialExecutor) {
+      _swiftJobRun(self, executor)
+  }
+}
 
 /// A unit of scheduleable work.
 ///
@@ -79,8 +84,7 @@ public struct Job: Sendable {
   }
 
   public var priority: JobPriority {
-    // let raw = _swift_concurrency_jobPriority(UnownedJob(context: self.context)) // TODO: do we also surface this or the base priority?
-    let raw = _taskCurrentPriority(context as! Builtin.NativeObject)
+    let raw = _swift_concurrency_jobPriority(UnownedJob(context: self.context))
     return JobPriority(rawValue: raw)
   }
 

test/Concurrency/Runtime/custom_executors_assume_main_asyncmain.swift

@@ -1,4 +1,4 @@
-// RUN: %target-run-simple-swift( -Xfrontend enable-experimental-move-only -Xfrontend -disable-availability-checking %import-libdispatch -parse-as-library) | %FileCheck %s
+// RUN: %target-run-simple-swift( -Xfrontend -enable-experimental-move-only -Xfrontend -disable-availability-checking %import-libdispatch -parse-as-library) | %FileCheck %s
 
 // REQUIRES: concurrency
 // REQUIRES: executable_test

test/Concurrency/Runtime/custom_executors_assume_main_asyncmain_crash.swift

@@ -1,4 +1,4 @@
-// RUN: %target-run-simple-swift( -Xfrontend -enable-experimental-move-only -Xfrontend -disable-availability-checking %import-libdispatch -parse-as-library) | %FileCheck %s
+// RUN: %target-run-simple-swift( -Xfrontend -enable-experimental-move-only -Xfrontend -disable-availability-checking %import-libdispatch -parse-as-library) | %FileCheck %s --dump-input=always
 
 // REQUIRES: concurrency
 // REQUIRES: executable_test
@@ -41,9 +41,6 @@ actor Custom {
     await Task() {
       await actor.report()
     }.value
-    await Task(priority: .low) {
-      await actor.report()
-    }.value
     print("end")
   }
 }

test/Concurrency/Runtime/custom_executors_default.swift

@@ -24,30 +24,6 @@ extension WithSpecifiedExecutor {
   }
 }
 
-final class InlineExecutor: SpecifiedExecutor, CustomStringConvertible {
-  let name: String
-
-  init(_ name: String) {
-    self.name = name
-  }
-
-  public func enqueue(_ job: UnownedJob) {
-    print("\(self): enqueue")
-    job.runSynchronously(on: self.asUnownedSerialExecutor())
-    print("\(self): after run")
-  }
-
-  public func enqueue(_ job: __owned Job) {
-    print("\(self): enqueue")
-    job.runSynchronously(on: self)
-    print("\(self): after run")
-  }
-
-  var description: Swift.String {
-    "InlineExecutor(\(name))"
-  }
-}
-
 final class NaiveQueueExecutor: SpecifiedExecutor, CustomStringConvertible {
   let queue: DispatchQueue
 
@@ -58,7 +34,7 @@ final class NaiveQueueExecutor: SpecifiedExecutor, CustomStringConvertible {
   public func enqueue(_ job: UnownedJob) {
     print("\(self): enqueue")
     queue.sync {
-      job.runSynchronously(on: self)
+      job.runSynchronously(on: self.asUnownedSerialExecutor())
     }
     print("\(self): after run")
   }
@@ -67,7 +43,7 @@ final class NaiveQueueExecutor: SpecifiedExecutor, CustomStringConvertible {
     print("\(self): enqueue")
     let unowned = UnownedJob(job)
     queue.sync {
-      unowned.runSynchronously(on: self)
+      unowned.runSynchronously(on: self.asUnownedSerialExecutor())
     }
     print("\(self): after run")
   }
@@ -89,7 +65,7 @@ actor MyActor: WithSpecifiedExecutor {
   }
 
   func test(expectedExecutor: some SerialExecutor, expectedQueue: DispatchQueue) {
-    precondition(_taskIsOnExecutor(expectedExecutor), "Expected to be on: \(expectedExecutor)")
+    // FIXME(waiting on preconditions to merge): preconditionTaskOnExecutor(expectedExecutor, "Expected to be on: \(expectedExecutor)")
     dispatchPrecondition(condition: .onQueue(expectedQueue))
     print("\(Self.self): on executor \(expectedExecutor)")
   }
@@ -109,9 +85,9 @@ actor MyActor: WithSpecifiedExecutor {
 }
 
 // CHECK:      begin
-// CHECK-NEXT: InlineExecutor(one): enqueue
-// CHECK-NEXT: MyActor: on executor InlineExecutor(one)
-// CHECK-NEXT: MyActor: on executor InlineExecutor(one)
-// CHECK-NEXT: MyActor: on executor InlineExecutor(one)
-// CHECK-NEXT: InlineExecutor(one): after run
+// CHECK-NEXT: NaiveQueueExecutor(<OS_dispatch_queue_serial: CustomQueue>): enqueue
+// CHECK-NEXT: MyActor: on executor NaiveQueueExecutor(<OS_dispatch_queue_serial: CustomQueue>)
+// CHECK-NEXT: MyActor: on executor NaiveQueueExecutor(<OS_dispatch_queue_serial: CustomQueue>)
+// CHECK-NEXT: MyActor: on executor NaiveQueueExecutor(<OS_dispatch_queue_serial: CustomQueue>)
+// CHECK-NEXT: NaiveQueueExecutor(<OS_dispatch_queue_serial: CustomQueue>): after run
 // CHECK-NEXT: end

test/Concurrency/Runtime/custom_executors_distributed.swift

@@ -16,6 +16,9 @@ func foo(a: FooClassDerived) {
 // CHECK:      key.kind: source.lang.swift.import.module.clang
 // CHECK-NEXT: key.name: "_SwiftConcurrencyShims"
 
+// CHECK:      key.kind: source.lang.swift.import.module.clang
+// CHECK-NEXT: key.name: "SwiftShims"
+
 // CHECK:      key.kind: source.lang.swift.import.module.clang
 // CHECK-NEXT: key.name: "Foo"
 // CHECK-NEXT: key.filepath: "{{.*[/\\]}}Foo{{.*}}.pcm"