An execution pool backed by a priority queue.
An execution pool backed by a priority queue. It limits the concurrent executions and the priority queue is ordered by the Ordering defined on the SchedulingContext.
An rate limiter pool backed by a priority queue.
An rate limiter pool backed by a priority queue. It rate limits the executions and the priority queue is ordered by the Ordering defined on the SchedulingContext.
The implementation is based on the tokens bucket algorithm.
A priority queue ordered by SchedulingContext priority.
Allow to make HTTP calls in a managed way with rate limiting.
Allow to make HTTP calls in a managed way with rate limiting.
It uses lolhttp as HTTP client.
Allow to fork process locally in a managed way.
Allow to fork process locally in a managed way.
It provides the sh interpolator that you can use to fork shell scripts:
sh"""hdfs dfs -cp /from /to""".exec()
Defines useful ExecutionPlatforms: