Changes the fallback_policy on the executor to :abort instead of using caller_runs. This will raise an Concurrent::RejectedExecutionError when posting to the executor when it does not have capacity. It then uses a Concurrent:Event to block the calling thread until the next task completes.
Issue #, if available:
Fixes #123
Description of changes:
By submitting this pull request, I confirm that my contribution is made under
the terms of the Apache 2.0 license.
Changes the
fallback_policy
on the executor to:abort
instead of usingcaller_runs
. This will raise anConcurrent::RejectedExecutionError
when posting to the executor when it does not have capacity. It then uses a Concurrent:Event to block the calling thread until the next task completes.Issue #, if available: Fixes #123
Description of changes:
By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.