Commit Graph

18 Commits

Author SHA1 Message Date
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