-
Notifications
You must be signed in to change notification settings - Fork 419
Closed
Description
- Concurrent::Promise fulfillment sets the promise state to :fulfilled if the block completes
- Concurrent::Edge futures .schedule scheduled execution in graph
- Concurrent::Edge futures .schedule scheduled execution
- Concurrent::Promise rejection passes the reason to all its children
- Concurrent::CyclicBarrier#wait without timeout should release all threads when their number matches the desired one
- Concurrent::TimerTask dereferenceable it should behave like dereferenceable defaults :freeze_on_deref to false
- Concurrent::ScheduledTask behavior it should behave like obligation #reason is set to error object of the exception when :rejected
- Concurrent::Synchronization Concurrent::Synchronization::Object#wait waiting thread is sleeping
- Concurrent::Edge futures .schedule scheduled execution
[ ] Concurrent::Condition with one waiting thread timeout #wait should return 0 or negative number if timed outremoved in 1.0[ ] Executor.executor_from_options returns the global io executor when :operation is falseremoved in 1.0- Concurrent::PureCountDownLatch spurious wake ups should resist to spurious wake ups with timeout
- Concurrent::Channel::UnbufferedChannel with one thread without timeout #push should block
Failure/Error: expect(t.status).to eq 'sleep' [ ] Executor.executor_from_options returns the global io executor when :operation is falseremoved in 1.0- Concurrent::ReentrantReadWriteLock write lock wakes up waiting readers when the write lock is released
- Concurrent::TimerSet execution does not execute tasks early
- Concurrent::PureCountDownLatch spurious wake ups should resist to spurious wake ups with timeout
- Concurrent::Async#async sets the reason when giving too many optional arguments
- Concurrent::Channel::UnbufferedChannel with one thread without timeout #pop should block
- Concurrent::Edge::LockFreeLinkedSet#remove in a multi-threaded environment adds the items to the set
- Concurrent::TimerSet execution executes all tasks scheduled for the same time
- Concurrent::TimerSet execution passes all arguments to the task on execution
- Executor.executor_from_options returns the global io executor when :executor is :io
- Concurrent::TimerSet termination rejects tasks once shutdown
- Concurrent::Future#initialize uses the global io executor by default
- Concurrent::Agent#restart when #failed? does not clear the action queue when :clear_actions is false
- Concurrent::TimerSet termination cancels all pending tasks on #kill
- Concurrent::Agent#restart when #failed? does not clear the action queue when :clear_actions is not given
- Concurrent::Edge::LockFreeLinkedSet#remove in a multi-threaded environment does not recognize the existence of the item when removed
- Concurrent::Actor termination terminates with all its children
- Concurrent::Actor pool supports asks
Metadata
Metadata
Assignees
Labels
choreGem maintenance tasks.Gem maintenance tasks.