Aaron Piotrowski
1988e109ab
Fix awaiting worker creation
2023-05-21 21:46:59 -05:00
Aaron Piotrowski
37850ff591
Fix assigning workers to waiting tasks
...
Fixes #177 .
2023-05-12 17:42:36 -05:00
Aaron Piotrowski
a4edad0d08
Add await() shortcut to Execution
...
Renamed getResult() to getFuture()
2023-02-14 21:30:55 -06:00
Niklas Keller
abf5fe195b
Rename DefaultWorker* to ContextWorker*
2023-02-14 21:31:30 +01:00
Aaron Piotrowski
9e5eec211a
Declare strict types
2022-12-17 15:49:26 -06:00
Aaron Piotrowski
7ba0dd24de
Fix pushing dead worker back into pool
2022-11-28 22:13:52 -06:00
Niklas Keller
5348d43129
Rename Job → Execution, enqueue → submit
2022-02-06 22:31:15 +01:00
Aaron Piotrowski
5d8a9deeca
Low-hanging fruit
2022-02-06 11:06:00 -06:00
Aaron Piotrowski
0c9fdff967
Initial WIP
2022-02-06 00:30:41 -06:00
Aaron Piotrowski
a45aa6370d
Refactor worker tasks to have a communication channel
2021-12-20 17:24:13 -06:00
Aaron Piotrowski
e2b444a004
Rename enqueue to execute and remove enqueueCallable
2021-12-17 23:55:25 -06:00
Aaron Piotrowski
758eaa45c2
Add LocalChannel and refactor Channel
...
Channels can now call receive multiple times, but they cannot send null, as this is now used to indicate the channel has closed, similar to pipelines and streams.
2021-12-12 10:30:42 -06:00
Aaron Piotrowski
350c769ab0
Update for recent dependency changes
2021-12-11 09:59:42 -06:00
Aaron Piotrowski
3602a615ce
Update for Amp and Revolt changes
2021-10-15 16:49:03 -05:00
Niklas Keller
477025c44d
Use revolt
2021-03-27 08:05:02 +01:00
Aaron Piotrowski
59a8822403
Refactor for Amp v3
2020-10-07 23:04:29 -05:00
Niklas Keller
b722da1d5a
Fix tests
2020-04-23 21:30:44 +02:00
Aaron Piotrowski
81b72bbeac
Add error trigger if a worker fails
2020-04-07 15:26:46 -05:00