[wasm] Make Thread APIs available on WASI target

Recent wasi-libc versions include pthreads support for wasip1-threads
target and a stub implementation for wasip1 target.

Author: kateinoigakukun

Sources/CoreFoundation/CFPlatform.c

@@ -1715,43 +1715,37 @@ typedef struct _CFThreadSpecificData {
 __stdcall
 #endif
 static void _CFThreadSpecificDestructor(void *ctx) {
-#if SWIFT_CORELIBS_FOUNDATION_HAS_THREADS
 #if TARGET_OS_WIN32
     _CFThreadSpecificData *data = (_CFThreadSpecificData *)ctx;
     FlsSetValue(data->key, NULL);
     swift_release(data->value);
     free(data);
-#else
+#elif defined(_REENTRANT)
     swift_release(ctx);
 #endif
-#endif
 }
 
 _CFThreadSpecificKey _CFThreadSpecificKeyCreate() {
-#if SWIFT_CORELIBS_FOUNDATION_HAS_THREADS
     _CFThreadSpecificKey key;
 #if TARGET_OS_WIN32
     key = FlsAlloc(_CFThreadSpecificDestructor);
-#else
+#elif defined(_REENTRANT)
     pthread_key_create(&key, &_CFThreadSpecificDestructor);
-#endif
-    return key;
 #else
-    return 0;
+    key = 0;
 #endif
+    return key;
 }
 
 CFTypeRef _Nullable _CFThreadSpecificGet(_CFThreadSpecificKey key) {
-#if SWIFT_CORELIBS_FOUNDATION_HAS_THREADS
 #if TARGET_OS_WIN32
     _CFThreadSpecificData *data = (_CFThreadSpecificData *)FlsGetValue(key);
     if (data == NULL) {
         return NULL;
     }
     return data->value;
-#else
+#elif defined(_REENTRANT)
     return (CFTypeRef)pthread_getspecific(key);
-#endif
 #else
     return NULL;
 #endif
@@ -1761,7 +1755,6 @@ void _CFThreadSpecificSet(_CFThreadSpecificKey key, CFTypeRef _Nullable value) {
     // Intentionally not calling `swift_release` for previous value.
     // OperationQueue uses these API (through NSThreadSpecific), and balances
     // retain count manually.
-#if SWIFT_CORELIBS_FOUNDATION_HAS_THREADS
 #if TARGET_OS_WIN32
     free(FlsGetValue(key));
 
@@ -1778,20 +1771,17 @@ void _CFThreadSpecificSet(_CFThreadSpecificKey key, CFTypeRef _Nullable value) {
     }
 
     FlsSetValue(key, data);
-#else
+#elif defined(_REENTRANT)
     if (value != NULL) {
         swift_retain((void *)value);
         pthread_setspecific(key, value);
     } else {
         pthread_setspecific(key, NULL);
     }
 #endif
-#else
-#endif
 }
 
 _CFThreadRef _CFThreadCreate(const _CFThreadAttributes attrs, void *_Nullable (* _Nonnull startfn)(void *_Nullable), void *_CF_RESTRICT _Nullable context) {
-#if SWIFT_CORELIBS_FOUNDATION_HAS_THREADS
 #if TARGET_OS_WIN32
     DWORD dwCreationFlags = 0;
     DWORD dwStackSize = 0;
@@ -1807,18 +1797,16 @@ _CFThreadRef _CFThreadCreate(const _CFThreadAttributes attrs, void *_Nullable (*
     return (_CFThreadRef)_beginthreadex(NULL, dwStackSize,
                                         (_beginthreadex_proc_type)startfn,
                                         context, dwCreationFlags, NULL);
-#else
+#elif defined(_REENTRANT)
     _CFThreadRef thread;
     pthread_create(&thread, &attrs, startfn, context);
     return thread;
-#endif
 #else
     return NULL;
 #endif
 }
 
 CF_CROSS_PLATFORM_EXPORT int _CFThreadSetName(_CFThreadRef thread, const char *_Nonnull name) {
-#if SWIFT_CORELIBS_FOUNDATION_HAS_THREADS
 #if TARGET_OS_MAC
     if (pthread_equal(pthread_self(), thread)) {
         return pthread_setname_np(name);
@@ -1848,15 +1836,14 @@ CF_CROSS_PLATFORM_EXPORT int _CFThreadSetName(_CFThreadRef thread, const char *_
 #elif TARGET_OS_BSD
     pthread_set_name_np(thread, name);
     return 0;
-#endif
-#else
+#elif TARGET_OS_WASI
+    // No thread naming support in WASI
     return -1;
 #endif
 }
 
 // `buf` must be null-terminated
 CF_CROSS_PLATFORM_EXPORT int _CFThreadGetName(char *buf, int length) {
-#if SWIFT_CORELIBS_FOUNDATION_HAS_THREADS
 #if TARGET_OS_MAC
     return pthread_getname_np(pthread_self(), buf, length);
 #elif TARGET_OS_ANDROID
@@ -1902,11 +1889,11 @@ CF_CROSS_PLATFORM_EXPORT int _CFThreadGetName(char *buf, int length) {
     LocalFree(pszThreadDescription);
 
     return 0;
-#endif
-    return -1;
-#else
+#elif TARGET_OS_WASI
+    // No thread naming support in WASI
     return -1;
 #endif
+    return -1;
 }
 
 CF_EXPORT char **_CFEnviron(void) {

Sources/Foundation/Thread.swift

@@ -7,7 +7,6 @@
 // See http://swift.org/CONTRIBUTORS.txt for the list of Swift project authors
 //
 
-#if canImport(Dispatch)
 @_implementationOnly import CoreFoundation
 #if os(Windows)
 import WinSDK
@@ -19,6 +18,8 @@ import WinSDK
 @preconcurrency import Musl
 #elseif canImport(Bionic)
 @preconcurrency import Bionic
+#elseif canImport(WASILibc) && _runtime(_multithreaded)
+import wasi_pthread
 #endif
 
 // WORKAROUND_SR9811
@@ -124,7 +125,11 @@ open class Thread : NSObject {
     }
 
     open class func isMultiThreaded() -> Bool {
+#if _runtime(_multithreaded)
         return true
+#else
+        return false
+#endif
     }
 
     @available(*, noasync)
@@ -201,13 +206,18 @@ open class Thread : NSObject {
 #endif
     }
 
+    #if os(WASI)
+    @available(*, unavailable, message: "exit() is not available on WASI")
+    #endif
     @available(*, noasync)
     open class func exit() {
+#if !os(WASI)
         Thread.current._status = .finished
 #if os(Windows)
         ExitThread(0)
 #else
         pthread_exit(nil)
+#endif
 #endif
     }
 
@@ -248,7 +258,9 @@ open class Thread : NSObject {
 #if !os(Windows)
         let _ = withUnsafeMutablePointer(to: &_attr) { attr in
             pthread_attr_init(attr)
+            #if !os(WASI) // WASI does not support scheduling contention scope
             pthread_attr_setscope(attr, Int32(PTHREAD_SCOPE_SYSTEM))
+            #endif
             pthread_attr_setdetachstate(attr, Int32(PTHREAD_CREATE_DETACHED))
         }
 #endif
@@ -385,7 +397,7 @@ open class Thread : NSObject {
         let maxSupportedStackDepth = 128;
         let addrs = UnsafeMutablePointer<UnsafeMutableRawPointer?>.allocate(capacity: maxSupportedStackDepth)
         defer { addrs.deallocate() }
-#if os(Android) || os(OpenBSD) || canImport(Musl)
+#if os(Android) || os(OpenBSD) || canImport(Musl) || os(WASI)
         let count = 0
 #elseif os(Windows)
         let count = RtlCaptureStackBackTrace(0, DWORD(maxSupportedStackDepth),
@@ -408,7 +420,7 @@ open class Thread : NSObject {
     }
 
     open class var callStackSymbols: [String] {
-#if os(Android) || os(OpenBSD) || canImport(Musl)
+#if os(Android) || os(OpenBSD) || canImport(Musl) || os(WASI)
         return []
 #elseif os(Windows)
         let hProcess: HANDLE = GetCurrentProcess()
@@ -478,4 +490,3 @@ extension NSNotification.Name {
     public static let NSDidBecomeSingleThreaded = NSNotification.Name(rawValue: "NSDidBecomeSingleThreadedNotification")
     public static let NSThreadWillExit = NSNotification.Name(rawValue: "NSThreadWillExitNotification")
 }
-#endif