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

Improve doWork's backwards compatibility.

Browse Source
This commit is contained in:
Joseph Cloutier
2023-03-02 14:00:37 -05:00
parent 82242e2c1c
commit 94ecdeb7df
1 changed files with 28 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
src/lime/system/ThreadPool.hx
View File

@@ -139,7 +139,7 @@ class ThreadPool extends WorkOutput
public var onRun(default, null) = new Event<State->Void>();
@:deprecated("Instead pass the callback to ThreadPool.run().")
@:noCompletion @:dox(hide) public var doWork(get, never):{ add: (Dynamic->Void)->Void };
@:noCompletion @:dox(hide) public var doWork(get, never):PseudoEvent;
private var __doWork:WorkFunction<State->WorkOutput->Void>;
private var __activeJobs:JobList = new JobList();
@@ -603,26 +603,37 @@ class ThreadPool extends WorkOutput
// Note the distinction between `doWork` and `__doWork`: the former is for
// backwards compatibility, while the latter is always used.
private function get_doWork():{ add: (Dynamic->Void) -> Void }
private function get_doWork():PseudoEvent
{
return {
add: function(callback:Dynamic->Void)
{
#if html5
if (mode == MULTI_THREADED)
throw "Unsupported operation; instead pass the callback to ThreadPool's constructor.";
#end
__doWork = #if (lime_threads && html5) { func: #end
function(state:State, output:WorkOutput):Void
{
callback(state);
}
#if (lime_threads && html5) } #end;
}
};
return this;
}
}
@:access(lime.system.ThreadPool)
private abstract PseudoEvent(ThreadPool) from ThreadPool {
public function add(callback:Dynamic -> Void):Void {
function callCallback(state:State, output:WorkOutput):Void
{
callback(state);
}
#if (lime_threads && html5)
if (this.mode == MULTI_THREADED)
throw "Unsupported operation; instead pass the callback to ThreadPool's constructor.";
else
this.__doWork = { func: callCallback };
#else
this.__doWork = callCallback;
#end
}
public inline function cancel():Void {}
public inline function dispatch():Void {}
public inline function has(callback:Dynamic -> Void):Bool { return this.__doWork != null; }
public inline function remove(callback:Dynamic -> Void):Void { this.__doWork = null; }
public inline function removeAll():Void { this.__doWork = null; }
}
@:forward
abstract JobList(List<JobData>)
{