Chalupa Petr
Chalupa Petr
I see the same error.
Sorry, I did not have free time left and could not attend concurrent-ruby for a while. Unfortunately the thread-pool uses `max_queue: 0` to make the queue unbounded. Remaining_capacity returns -1...
The current implementation indeed swallows the exception, which is not good. Unfortunately I cannot accept your contribution as is. Could you open a pull-request? it will make perfectly clear what...
Thanks, that's fine.
Postponing to 1.2 since it's not easily fixable since JRuby thread-pool is not using Ruby threads, the tasks probably need wrapping and raise on main thread or something similar.
@merqlove yeah that works thanks for the comment, the `array` should be a `Concurrent::Array` instance though. I've updated your comment.
@route I've put this on my list to revisit. Thanks for your interest.
@route thanks a lot! please have a look and open a PR with a prototype where we could discuss the desired change. Things to keen in mind: * The final...
Would something as follows work? ``` ruby def post_rails_job(pool, *args, &job) request_uuid = Thread.current[:rails_request_uuid] pool.post(request_uuid, job, *args) do |uuid, job, *args| begin Thread.current[:rails_request_uuid] = uuid job.call *args ensure Thread.current[:rails_request_uuid] =...
Ah sorry, my mistake. The example does not help with Futures. I see your problem and we should address it however the suggestion uses a global state which should be...