- New Win32Thread.

CHANGELOG.md

@@ -5,6 +5,7 @@
 - `Window`:
   - Added `showMessage`, `showConfirmationDialog` and `showDialog`.
   - Free some pointers.
+- New `Win32Thread`.
 
 ## 1.0.9
 

lib/src/win32_thread.dart

@@ -0,0 +1,68 @@
+import 'dart:ffi';
+
+import 'package:ffi/ffi.dart';
+import 'package:win32/win32.dart';
+
+// ignore_for_file: constant_identifier_names
+
+/// Handles Win32 Thread creation:
+class Win32Thread {
+  /// Creates a Win32 Thread.
+  /// - [threadFunction] is the entrypoint function of the Thread.
+  /// - [threadParam] is an optional parameter to be passed to [threadFunction].
+  static ({int threadID, int hThread})? createThread(
+      {required Pointer<NativeFunction<ThreadProc>> threadFunction,
+      Pointer<NativeType>? threadParam,
+      int flags = 0}) {
+    final threadIdPtr = calloc<Uint32>();
+
+    var hThread = CreateThread(
+      nullptr,
+      0,
+      threadFunction,
+      threadParam ?? nullptr,
+      flags,
+      threadIdPtr,
+    );
+
+    if (hThread == NULL) {
+      return null;
+    }
+
+    var threadId = threadIdPtr.value;
+
+    return (threadID: threadId, hThread: hThread);
+  }
+
+  static const WAIT_OBJECT_0 = 0x00000000;
+  static const WAIT_TIMEOUT = 0x00000102;
+  static const WAIT_ABANDONED = 0x00000080;
+  static const WAIT_FAILED = 0xFFFFFFFF;
+
+  /// Waits a thread to exit.
+  /// - Calls Win32 [WaitForSingleObject].
+  /// - Returns `null` if failed.
+  /// - Returns `true` if thread exited.
+  /// - Returns `false` on timeout.
+  static bool? waitThread(int hThread, {Duration? timeout}) {
+    int timeoutMs;
+    if (timeout != null) {
+      timeoutMs = timeout.inMilliseconds;
+      if (timeoutMs < 0) {
+        timeoutMs = 0;
+      }
+    } else {
+      timeoutMs = INFINITE;
+    }
+
+    var r = WaitForSingleObject(hThread, timeoutMs);
+
+    if (r == WAIT_OBJECT_0) {
+      return true;
+    } else if (r == WAIT_TIMEOUT) {
+      return false;
+    }
+
+    return null;
+  }
+}

lib/win32_gui.dart

@@ -3,10 +3,12 @@ library win32_gui;
 
 export 'dart:ffi';
 
+export 'package:ffi/ffi.dart' hide StringUtf8Pointer;
 export 'package:win32/win32.dart';
 
 export 'src/components/win32_component_button.dart';
 export 'src/components/win32_richedit.dart';
 export 'src/win32_constants.dart';
 export 'src/win32_constants_extra.dart';
 export 'src/win32_gui_base.dart';
+export 'src/win32_thread.dart';

test/win32_thread_test.dart

@@ -0,0 +1,27 @@
+@TestOn('windows')
+import 'package:test/test.dart';
+import 'package:win32_gui/win32_gui.dart';
+import 'package:win32_gui/win32_gui_logging.dart';
+
+int _threadFunction(Pointer<Utf16> param) {
+  return 0;
+}
+
+void main() {
+  logToConsole();
+
+  test('Win32 Thread', () async {
+    var t = Win32Thread.createThread(
+        threadFunction: Pointer.fromFunction<ThreadProc>(_threadFunction, 0),
+        threadParam: 'xyz'.toNativeUtf16());
+
+    expect(t, isNotNull);
+
+    expect(t!.hThread, isNot(equals(0)));
+    expect(t.threadID, isNot(equals(0)));
+
+    var tExited =
+        Win32Thread.waitThread(t.hThread, timeout: Duration(seconds: 1));
+    expect(tExited, isTrue);
+  });
+}