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

Use WorkFunction in Future.

Browse Source
This commit is contained in:
Joseph Cloutier
2022-03-14 18:34:48 -04:00
parent bcc1c854e7
commit 01a213b5fa
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/lime/app/Future.hx
View File

@@ -75,7 +75,7 @@ import lime.utils.Log;
will be ignored after the first time. To change it, use `FutureWork.recreateThreadPool()`. will be ignored after the first time. To change it, use `FutureWork.recreateThreadPool()`.
@see https://en.wikipedia.org/wiki/Cooperative_multitasking @see https://en.wikipedia.org/wiki/Cooperative_multitasking
**/ **/
public function new(work:Void->Null<T> = null, useThreads:Bool = true) public function new(work:WorkFunction<Void->Null<T>> = null, useThreads:Bool = true)
{ {
if (work != null) if (work != null)
{ {
@@ -320,7 +320,7 @@ import lime.utils.Log;
public static var maxThreads(default, set):Int = 1; public static var maxThreads(default, set):Int = 1;
@:allow(lime.app.Future) @:allow(lime.app.Future)
private static function queue<T>(work:Void->Null<T>, promise:Promise<T>, mode:ThreadMode = MULTI_THREADED):Void private static function queue<T>(work:WorkFunction<Void->Null<T>>, promise:Promise<T>, mode:ThreadMode = MULTI_THREADED):Void
{ {
if (threadPool == null) if (threadPool == null)
{ {
@@ -347,11 +347,11 @@ import lime.utils.Log;
} }
// Event Handlers // Event Handlers
private static function threadPool_doWork(state:{work:Void->Dynamic, promise:Promise<Dynamic>, ?result:Dynamic, ?error:Dynamic}, output:WorkOutput):Void private static function threadPool_doWork(state:{work:WorkFunction<Void->Dynamic>}, output:WorkOutput):Void
{ {
try try
{ {
var result = state.work(); var result = state.work.dispatch();
if (result != null) if (result != null)
{ {
output.sendComplete(result); output.sendComplete(result);