concurrent-ruby

concurrent-ruby copied to clipboard

should we use new c macros included with rubyc?

1

with https://github.com/ruby/ruby/pull/3983 , rubyc includes c macros to do atomic operations. should we use these for the atomic operations? * Operating system: linux / mac / win * Ruby implementation:...

dsisnero

I found that `Concurrent::Channel` is great for representing stream data. Initial problem was, that I needed to stream data in JRuby with Sinatra (so i stuck with Puma and was...

kvokka

concurrent-ruby-edge Channel.select consumes full(single core) cpu

1

``` * `concurrent-ruby` version: 1.1.7 * `concurrent-ruby-edge` used: yes ``` I am running this simple code and I see that `select` is not blocking on the `channels` and instead always...

adityacs

Passenger workers hang / segfault with Ruby 2.5 / concurrent-ruby 1.1.6

3

Thank you for all your hard work on the latest 1.1.6 release. I recently upgraded our app gems and started noticing the passenger workers would become unresponsive (request queue =...

astupka

`Promise.zip` seems to hang with any rejected promise in its collection for large enough collections (several hundred items). Here is a minimal repro: ```ruby 1.upto(1000).map do |n| puts n promises...

wjordan

Concurrent::Promises::Channel deadlock in example code

1

I'm running example from [Promises::Channel docs](https://ruby-concurrency.github.io/concurrent-ruby/master/Concurrent/Promises/Channel.html). ``` channel = Concurrent::Promises::Channel.new 2 log = Concurrent::Array.new # => [] def produce(channel, log, producer, i) log.push format "producer %d pushing %d", producer, i...

ilyacherevkov

I have been seeing a failure on and off when running concurrent-ruby's specs against JRuby head. I believe this failure in the cylic barrier specs may have a bug: ```...

headius

Waiting for Actor termination?

1

Is there an easy way to wait for an Actor to terminate? I'm aware that I can wait till all messages are processed: ```ruby actor = MyActor.spawn(name: 'actor') actor

mvgijssel

Deadlock on wait_for_termination

2

Hey, I have a deadlock problem, code snippet like this: ```ruby thread_pool = Concurrent::FixedThreadPool.new(3) res = Concurrent::ThreadLocalVar.new({}) while @queue.size > 0 do thread_pool.post do cur = @queue.pop build_res = start(cur)...

EarlofLemongrab

Backtrace propagation into the executor

6

When an error occurs within some code running inside concurrent-ruby executor, it ends up with something like this, while loosing the info about the true origin of the code: ```...

iNecas