AsyncUtils
tasks, async, await, actors and channels for java
This project tries to explore several approaches to simplify async/concurrent programming in Java. AsyncUtils basically consits of distilled versions of patterns that I implemented over the past years. The purpose isn't best-in class performance but rather reliability.
Sharing mutable state is usually avoided in concurrent programming. We use actors to reduce the negative impact of shared mutable state. Currently, there's only a reflection based actor. It will serve as prototype for VMF actors currently in development.
WARNING: WIP, needs Project Loom to unleash its full potential. The API might change over time.
Structured concurrency with Task Groups
Consider the following code:
// sequential
System.out.println("starting sequential:");
for(int i = 0; i < N; i++) {
doSomethingThatTakesAWhile(); // runs sequentially
}
Java offers multiple APIs to execute methods concurrently. But these APIs are a little baroque. AsyncUtils provides simpler APIs for that purpose.
Here's how we can perform the method calls inside the loop concurrently:
// concurrent
System.out.println("starting concurrent:");
Tasks.group(g -> {
for(int i = 0; i < N; i++) {
g.async(()->doSomethingThatTakesAWhile()); // runs concurrently
}
}).await();
// continues after all tasks have been executed
Of course, we could use Streams, Fork-Join APIs and Futures. But either the APIs require a lot of boilerplate code or they lack features such as control over how exceptions are handled or how to specify how many threads should be used to process the tasks.
6 Nov 29, 2022
19 Oct 8, 2021
213 Dec 15, 2022
24 May 10, 2022
3 Oct 17, 2021
16.6k Jan 4, 2023
956 Dec 30, 2022
52 Nov 1, 2022
225 Dec 24, 2022
2.2k Jan 8, 2023