kiss-lang/lime
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BackgroundWorker: Add hl flag

Browse Source 
Prevents hl from freezing up when using bgworker
This commit is contained in:
Chris Speciale
2024-10-16 00:34:09 -04:00
committed by GitHub
parent ccb7647827
commit 7dc3718551
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/lime/system/BackgroundWorker.hx
View File

@@ -69,7 +69,7 @@ class BackgroundWorker
public var onProgress = new Event<Dynamic->Void>(); public var onProgress = new Event<Dynamic->Void>();
@:noCompletion private var __runMessage:Dynamic; @:noCompletion private var __runMessage:Dynamic;
#if (cpp || neko) #if (cpp || neko || hl)
@:noCompletion private var __messageQueue:Deque<Dynamic>; @:noCompletion private var __messageQueue:Deque<Dynamic>;
@:noCompletion private var __workerThread:Thread; @:noCompletion private var __workerThread:Thread;
#end #end
@@ -87,7 +87,7 @@ class BackgroundWorker
{ {
canceled = true; canceled = true;
#if (cpp || neko) #if (cpp || neko || hl)
__workerThread = null; __workerThread = null;
#end #end
} }
@@ -102,7 +102,7 @@ class BackgroundWorker
completed = false; completed = false;
__runMessage = message; __runMessage = message;
#if (cpp || neko) #if (cpp || neko || hl)
__messageQueue = new Deque<Dynamic>(); __messageQueue = new Deque<Dynamic>();
__workerThread = Thread.create(__doWork); __workerThread = Thread.create(__doWork);
@@ -125,7 +125,7 @@ class BackgroundWorker
{ {
completed = true; completed = true;
#if (cpp || neko) #if (cpp || neko || hl)
__messageQueue.add(MESSAGE_COMPLETE); __messageQueue.add(MESSAGE_COMPLETE);
__messageQueue.add(message); __messageQueue.add(message);
#else #else
@@ -143,7 +143,7 @@ class BackgroundWorker
**/ **/
public function sendError(message:Dynamic = null):Void public function sendError(message:Dynamic = null):Void
{ {
#if (cpp || neko) #if (cpp || neko || hl)
__messageQueue.add(MESSAGE_ERROR); __messageQueue.add(MESSAGE_ERROR);
__messageQueue.add(message); __messageQueue.add(message);
#else #else
@@ -161,7 +161,7 @@ class BackgroundWorker
**/ **/
public function sendProgress(message:Dynamic = null):Void public function sendProgress(message:Dynamic = null):Void
{ {
#if (cpp || neko) #if (cpp || neko || hl)
__messageQueue.add(message); __messageQueue.add(message);
#else #else
if (!canceled) if (!canceled)
@@ -193,7 +193,7 @@ class BackgroundWorker
@:noCompletion private function __update(deltaTime:Int):Void @:noCompletion private function __update(deltaTime:Int):Void
{ {
#if (cpp || neko) #if (cpp || neko || hl)
var message = __messageQueue.pop(false); var message = __messageQueue.pop(false);
if (message != null) if (message != null)