Merge pull request #34776 from DougGregor/concurrency-basic-future

[Concurrency] Introduce a small executable test using asynchronous futures

Author: DougGregor

stdlib/public/Concurrency/Task.swift

@@ -146,6 +146,11 @@ extension Task {
     public func cancel() {
       Builtin.cancelAsyncTask(task)
     }
+
+    @available(*, deprecated, message: "This is a temporary hack")
+    public func run() {
+      runTask(task)
+    }
   }
 }
 
@@ -267,9 +272,6 @@ extension Task {
     let (task, context) =
       Builtin.createAsyncTaskFuture(flags.bits, nil, operation)
 
-    // FIXME: Launch the task on an executor... somewhere....
-    runTask(task)
-
     return Handle<T>(task: task)
   }
 
@@ -317,11 +319,6 @@ extension Task {
     let (task, context) =
       Builtin.createAsyncTaskFuture(flags.bits, nil, operation)
 
-    print(task)
-
-    // FIXME: Launch the task on an executor... somewhere....
-    runTask(task)
-
     return Handle<T>(task: task)
   }
 }

test/Concurrency/Runtime/basic_future.swift

@@ -0,0 +1,45 @@
+// RUN: %target-run-simple-swift(-Xfrontend -enable-experimental-concurrency) | %FileCheck %s
+// REQUIRES: executable_test
+// REQUIRES: concurrency
+// REQUIRES: OS=macosx
+
+import Dispatch
+
+extension DispatchQueue {
+  func async<R>(execute: @escaping () async -> R) -> Task.Handle<R> {
+    let handle = Task.runDetached(operation: execute)
+
+    // Run the task
+    _ = { self.async { handle.run() } }()
+
+    return handle
+  }
+}
+
+func formGreeting(name: String) async -> String {
+  return "Hello \(name) from async world"
+}
+
+func test(name: String) {
+  let taskHandle = DispatchQueue.main.async { () async -> String in
+    let greeting = await formGreeting(name: name)
+    return greeting + "!"
+  }
+
+  _ = DispatchQueue.main.async { () async in
+    // CHECK: Sleeping
+    print("Sleeping...")
+    sleep(2)
+    let result = await try! taskHandle.get()
+    // CHECK: Hello Ted from async world
+    print(result)
+    assert(result == "Hello Ted from async world!")
+    exit(0)
+  }
+
+  print("Main task")
+}
+
+test(name: "Ted")
+
+dispatchMain()