Upgrading concurrent-ruby 0.5 to 0.6
Unknown0.5.0 → 0.6.1
Fetching 4 releases from GitHub…0 / 4
UnknownUpgrade verdict
DepDelta is still reading the notes for this range, so breaking changes can't be ruled out yet.
In plain terms
- DepDelta is still reading the release notes in this range, so it can't rule out breaking changes yet.
- This page updates as the notes come in.
Must act Still reading release notes
DepDelta is still reading the release notes in this range. This updates as they come in.
Ruby requirement changed in 0.6.0.pre.1: >= 1.9.2 → >= 1.9.3.
API changes
Generated by DepDelta from published Ruby source. Not mixed with prose notes.
- added:
static method Concurrent.abort_transaction() - added:
static method Concurrent.atomically() - added:
static method Concurrent.configuration() - added:
static method Concurrent.configure() - added:
static method Concurrent.dataflow_with(_, *) - added:
static method Concurrent.physical_processor_count() - added:
static method Concurrent.processor_count() - added:
static method Concurrent.timer(_, *)
- removed:
class Channel < Actor - removed:
class NullThreadPool - removed:
const CachedThreadPool.DEFAULT_THREAD_IDLETIME - removed:
const CachedThreadPool.MAX_POOL_SIZE - removed:
const CachedThreadPool.MIN_POOL_SIZE - removed:
const FixedThreadPool.MAX_POOL_SIZE - removed:
const FixedThreadPool.MIN_POOL_SIZE - removed:
constructor AtomicFixnum(_ = …) - removed:
constructor CachedThreadPool(_ = …) - removed:
constructor Channel() - removed:
constructor CountDownLatch(_) - removed:
constructor FixedThreadPool(_, _ = …) - removed:
method Agent.add_observer(_, _ = …) - removed:
method Agent.add_watch(_, _ = …) - removed:
method Agent.delete_observer(_) - removed:
method AtomicFixnum.down() - removed:
method AtomicFixnum.up() - removed:
method CachedThreadPool.<<(_) - removed:
method CachedThreadPool.kill() - removed:
method CachedThreadPool.length() - removed:
method CachedThreadPool.on_end_task(_) - removed:
method CachedThreadPool.on_worker_exit(_) - removed:
method CachedThreadPool.post(*) - removed:
method CachedThreadPool.running?() - removed:
method CachedThreadPool.shutdown() - removed:
method CachedThreadPool.wait_for_termination(_ = …) - removed:
method CountDownLatch.count() - removed:
method CountDownLatch.count_down() - removed:
method CountDownLatch.wait(_ = …) - removed:
method FixedThreadPool.<<(_) - removed:
method FixedThreadPool.clean_pool() - removed:
method FixedThreadPool.create_worker_thread() - removed:
method FixedThreadPool.drain_pool() - removed:
method FixedThreadPool.fill_pool() - removed:
method FixedThreadPool.kill() - removed:
method FixedThreadPool.length() - removed:
method FixedThreadPool.on_end_task(_) - removed:
method FixedThreadPool.on_start_task(_) - removed:
method FixedThreadPool.on_worker_exit(_) - removed:
method FixedThreadPool.post(*) - removed:
method FixedThreadPool.running?() - removed:
method FixedThreadPool.shutdown() - removed:
method FixedThreadPool.wait_for_termination(_ = …) - removed:
method JavaAtomicFixnum.allocate_storage(_) - removed:
method MutexAtomicFixnum.allocate_storage(_) - removed:
method NullThreadPool.<<(_) - removed:
method NullThreadPool.post(*) - removed:
method TimerTask.kill() - removed:
module JavaAtomicFixnum - removed:
module MutexAtomicFixnum - removed:
module UsesGlobalThreadPool - removed:
property CachedThreadPool.max_threads: accessor - removed:
property FixedThreadPool.max_threads: accessor - removed:
property TimerTask.execution_interval: reader - removed:
property TimerTask.timeout_interval: reader - removed:
protected method CachedThreadPool.create_worker_thread() - removed:
protected method CachedThreadPool.prune_stale_workers() - removed:
protected method Channel.on_stop() - removed:
protected method ScheduledTask.work() - removed:
protected method TimerTask.on_run() - removed:
protected method TimerTask.on_stop() - removed:
protected method TimerTask.on_task() - removed:
static method NullThreadPool.post(*) - changed:
class AtomicFixnum → class AtomicFixnum < JavaAtomicFixnum - changed:
class CachedThreadPool → class CachedThreadPool < JavaCachedThreadPool - changed:
class CountDownLatch → class CountDownLatch < JavaCountDownLatch - changed:
class FixedThreadPool → class FixedThreadPool < JavaFixedThreadPool - changed:
class ScheduledTask → class ScheduledTask < IVar - changed:
constructor SafeTaskExecutor(_) → constructor SafeTaskExecutor(_, _ = …) - changed:
method CopyOnNotifyObserverSet.add_observer(_, _ = …) → method CopyOnNotifyObserverSet.add_observer(_ = …, _ = …) - changed:
method CopyOnWriteObserverSet.add_observer(_, _ = …) → method CopyOnWriteObserverSet.add_observer(_ = …, _ = …) - changed:
method IVar.add_observer(_, _ = …) → method IVar.add_observer(_ = …, _ = …) - changed:
method SafeTaskExecutor.execute() → method SafeTaskExecutor.execute(*) - changed:
method ScheduledTask.add_observer(_, _ = …) → method ScheduledTask.add_observer(*) - changed:
method TimerTask.cancel() → method TimerTask.cancel(*) - changed:
method TimerTask.terminate() → method TimerTask.terminate(*) - changed:
protected method TimerTask.execute_task() → protected method TimerTask.execute_task(_) - changed:
static method Promise.execute() → static method Promise.execute(_ = …) - changed:
static method Promise.fulfill(_) → static method Promise.fulfill(_, _ = …) - changed:
static method Promise.reject(_) → static method Promise.reject(_, _ = …) - added:
class Atomic < MutexAtomic - added:
class AtomicBoolean < JavaAtomicBoolean - added:
class BlockingRingBuffer - added:
class BufferedChannel - added:
class Configuration - added:
class ConfigurationError < StandardError - added:
class CyclicBarrier - added:
class Delay - added:
class Exchanger - added:
class InitializationError < StandardError - added:
class JavaAtomicBoolean - added:
class JavaAtomicFixnum - added:
class JavaCachedThreadPool < JavaThreadPoolExecutor - added:
class JavaCountDownLatch - added:
class JavaFixedThreadPool < JavaThreadPoolExecutor - added:
class JavaPriorityQueue - added:
class JavaSingleThreadExecutor - added:
class JavaThreadPoolExecutor - added:
class LifecycleError < StandardError - added:
class MaxRestartFrequencyError < StandardError - added:
class MutexAtomic - added:
class MutexAtomicBoolean - added:
class MutexAtomicFixnum - added:
class MutexCountDownLatch - added:
class MutexPriorityQueue - added:
class PerThreadExecutor - added:
class PriorityQueue < JavaPriorityQueue - added:
class ProcessorCounter - added:
class RejectedExecutionError < StandardError - added:
class RingBuffer - added:
class RubyCachedThreadPool < RubyThreadPoolExecutor - added:
class RubyFixedThreadPool < RubyThreadPoolExecutor - added:
class RubySingleThreadExecutor - added:
class RubyThreadPoolExecutor - added:
class RubyThreadPoolWorker - added:
class SerializedExecution - added:
class SingleThreadExecutor < JavaSingleThreadExecutor - added:
class TVar - added:
class ThreadPoolExecutor < JavaThreadPoolExecutor - added:
class TimerSet - added:
class Transaction - added:
class UnbufferedChannel - added:
class WaitableList - added:
const JavaThreadPoolExecutor.DEFAULT_MAX_POOL_SIZE - added:
const JavaThreadPoolExecutor.DEFAULT_MAX_QUEUE_SIZE - added:
const JavaThreadPoolExecutor.DEFAULT_MIN_POOL_SIZE - added:
const JavaThreadPoolExecutor.DEFAULT_THREAD_IDLETIMEOUT - added:
const JavaThreadPoolExecutor.OVERFLOW_POLICIES - added:
const RubyThreadPoolExecutor.DEFAULT_MAX_POOL_SIZE - added:
const RubyThreadPoolExecutor.DEFAULT_MAX_QUEUE_SIZE - added:
const RubyThreadPoolExecutor.DEFAULT_MIN_POOL_SIZE - added:
const RubyThreadPoolExecutor.DEFAULT_THREAD_IDLETIMEOUT - added:
const RubyThreadPoolExecutor.OVERFLOW_POLICIES - added:
constructor BlockingRingBuffer(_) - added:
constructor BufferedChannel(_) - added:
constructor Configuration() - added:
constructor CyclicBarrier(_) - added:
constructor Delay(_ = …) - added:
constructor Exchanger(_ = …) - added:
constructor JavaAtomicBoolean(_ = …) - added:
constructor JavaAtomicFixnum(_ = …) - added:
constructor JavaCachedThreadPool(_ = …) - added:
constructor JavaCountDownLatch(_) - added:
constructor JavaFixedThreadPool(_, _ = …) - added:
constructor JavaPriorityQueue(_ = …) - added:
constructor JavaSingleThreadExecutor(_ = …) - added:
constructor JavaThreadPoolExecutor(_ = …) - added:
constructor MutexAtomic(_ = …) - added:
constructor MutexAtomicBoolean(_ = …) - added:
constructor MutexAtomicFixnum(_ = …) - added:
constructor MutexCountDownLatch(_) - added:
constructor MutexPriorityQueue(_ = …) - added:
constructor ProcessorCounter() - added:
constructor RingBuffer(_) - added:
constructor RubyCachedThreadPool(_ = …) - added:
constructor RubyFixedThreadPool(_, _ = …) - added:
constructor RubySingleThreadExecutor(_ = …) - added:
constructor RubyThreadPoolExecutor(_ = …) - added:
constructor RubyThreadPoolWorker(_, _) - added:
constructor SerializedExecution() - added:
constructor TVar(_) - added:
constructor TimerSet(_ = …) - added:
constructor Transaction() - added:
constructor UnbufferedChannel() - added:
constructor WaitableList() - added:
method Agent.await(_ = …) - added:
method Agent.post_off() - added:
method Async.async() - added:
method Async.await() - added:
method Async.delay() - added:
method Async.future() - added:
method Async.init_mutex() - added:
method BlockingRingBuffer.capacity() - added:
method BlockingRingBuffer.count() - added:
method BlockingRingBuffer.empty?() - added:
method BlockingRingBuffer.full?() - added:
method BlockingRingBuffer.peek() - added:
method BlockingRingBuffer.put(_) - added:
method BlockingRingBuffer.take() - added:
method BufferedChannel.buffer_queue_size() - added:
method BufferedChannel.pop() - added:
method BufferedChannel.probe_set_size() - added:
method BufferedChannel.push(_) - added:
method BufferedChannel.remove_probe(_) - added:
method BufferedChannel.select(_) - added:
method Configuration.global_operation_pool() - added:
method Configuration.global_task_pool() - added:
method Configuration.global_timer_set() - added:
method Configuration.new_operation_pool() - added:
method Configuration.new_task_pool() - added:
method Configuration.no_logger() - added:
method CyclicBarrier.broken?() - added:
method CyclicBarrier.number_waiting() - added:
method CyclicBarrier.parties() - added:
method CyclicBarrier.reset() - added:
method CyclicBarrier.wait(_ = …) - added:
method Delay.reconfigure() - added:
method Delay.value() - added:
method Event.try?() - added:
method Exchanger.exchange(_, _ = …) - added:
method Executor.can_overflow?() - added:
method JavaAtomicBoolean.false?() - added:
method JavaAtomicBoolean.make_false() - added:
method JavaAtomicBoolean.make_true() - added:
method JavaAtomicBoolean.true?() - added:
method JavaAtomicBoolean.value() - added:
method JavaAtomicFixnum.down() - added:
method JavaAtomicFixnum.up() - added:
method JavaCountDownLatch.count() - added:
method JavaCountDownLatch.count_down() - added:
method JavaCountDownLatch.wait(_ = …) - added:
method JavaExecutor.<<(_) - added:
method JavaExecutor.kill() - added:
method JavaExecutor.post(*) - added:
method JavaExecutor.running?() - added:
method JavaExecutor.shutdown() - added:
method JavaExecutor.shutdown?() - added:
method JavaExecutor.shuttingdown?() - added:
method JavaExecutor.wait_for_termination(_) - added:
method JavaPriorityQueue.clear() - added:
method JavaPriorityQueue.delete(_) - added:
method JavaPriorityQueue.deq() - added:
method JavaPriorityQueue.empty?() - added:
method JavaPriorityQueue.enq(_) - added:
method JavaPriorityQueue.has_priority?(_) - added:
method JavaPriorityQueue.include?(_) - added:
method JavaPriorityQueue.length() - added:
method JavaPriorityQueue.peek() - added:
method JavaPriorityQueue.pop() - added:
method JavaPriorityQueue.push(_) - added:
method JavaPriorityQueue.shift() - added:
method JavaPriorityQueue.size() - added:
method JavaThreadPoolExecutor.can_overflow?() - added:
method JavaThreadPoolExecutor.completed_task_count() - added:
method JavaThreadPoolExecutor.current_length() - added:
method JavaThreadPoolExecutor.idletime() - added:
method JavaThreadPoolExecutor.largest_length() - added:
method JavaThreadPoolExecutor.length() - added:
method JavaThreadPoolExecutor.max_length() - added:
method JavaThreadPoolExecutor.min_length() - added:
method JavaThreadPoolExecutor.queue_length() - added:
method JavaThreadPoolExecutor.remaining_capacity() - added:
method JavaThreadPoolExecutor.running?() - added:
method JavaThreadPoolExecutor.scheduled_task_count() - added:
method JavaThreadPoolExecutor.shutdown() - added:
method JavaThreadPoolExecutor.status() - added:
method Logging.log(_, _, _ = …) - added:
method MutexAtomic.compare_and_set(_, _) - added:
method MutexAtomic.modify() - added:
method MutexAtomic.value() - added:
method MutexAtomicBoolean.false?() - added:
method MutexAtomicBoolean.make_false() - added:
method MutexAtomicBoolean.make_true() - added:
method MutexAtomicBoolean.true?() - added:
method MutexAtomicBoolean.value() - added:
method MutexAtomicFixnum.down() - added:
method MutexAtomicFixnum.up() - added:
method MutexCountDownLatch.count() - added:
method MutexCountDownLatch.count_down() - added:
method MutexCountDownLatch.wait(_ = …) - added:
method MutexPriorityQueue.clear() - added:
method MutexPriorityQueue.delete(_) - added:
method MutexPriorityQueue.deq() - added:
method MutexPriorityQueue.empty?() - added:
method MutexPriorityQueue.enq(_) - added:
method MutexPriorityQueue.has_priority?(_) - added:
method MutexPriorityQueue.include?(_) - added:
method MutexPriorityQueue.length() - added:
method MutexPriorityQueue.peek() - added:
method MutexPriorityQueue.pop() - added:
method MutexPriorityQueue.push(_) - added:
method MutexPriorityQueue.shift() - added:
method MutexPriorityQueue.size() - added:
method Obligation.exception(*) - added:
method Obligation.no_error!(_ = …) - added:
method Obligation.value!(_ = …) - added:
method Obligation.wait(_ = …) - added:
method Observable.add_observer(*) - added:
method Observable.count_observers() - added:
method Observable.delete_observer(*) - added:
method Observable.delete_observers() - added:
method Observable.with_observer(*) - added:
method OptionsParser.get_executor_from(_ = …) - added:
method OptionsParser.get_operation_executor_from(_ = …) - added:
method OptionsParser.get_task_executor_from(_ = …) - added:
method PerThreadExecutor.<<(_) - added:
method PerThreadExecutor.post(*) - added:
method ProcessorCounter.physical_processor_count() - added:
method ProcessorCounter.processor_count() - added:
method RingBuffer.capacity() - added:
method RingBuffer.count() - added:
method RingBuffer.empty?() - added:
method RingBuffer.full?() - added:
method RingBuffer.offer(_) - added:
method RingBuffer.peek() - added:
method RingBuffer.poll() - added:
method RubyExecutor.<<(_) - added:
method RubyExecutor.kill() - added:
method RubyExecutor.post(*) - added:
method RubyExecutor.running?() - added:
method RubyExecutor.shutdown() - added:
method RubyExecutor.shutdown?() - added:
method RubyExecutor.shuttingdown?() - added:
method RubyExecutor.wait_for_termination(_ = …) - added:
method RubyThreadPoolExecutor.can_overflow?() - added:
method RubyThreadPoolExecutor.current_length() - added:
method RubyThreadPoolExecutor.length() - added:
method RubyThreadPoolExecutor.on_end_task() - added:
method RubyThreadPoolExecutor.on_worker_exit(_) - added:
method RubyThreadPoolExecutor.queue_length() - added:
method RubyThreadPoolExecutor.remaining_capacity() - added:
method RubyThreadPoolExecutor.status() - added:
method RubyThreadPoolWorker.dead?() - added:
method RubyThreadPoolWorker.kill() - added:
method RubyThreadPoolWorker.last_activity() - added:
method RubyThreadPoolWorker.run(_ = …) - added:
method RubyThreadPoolWorker.status() - added:
method SerializedExecution.post(_, *) - added:
method TVar.unsafe_increment_version() - added:
method TVar.unsafe_lock() - added:
method TVar.unsafe_value() - added:
method TVar.unsafe_version() - added:
method TVar.value() - added:
method TimerSet.kill() - added:
method TimerSet.post(_, *) - added:
method TimerTask.execute() - added:
method TimerTask.execution_interval() - added:
method TimerTask.run!(*) - added:
method TimerTask.run() - added:
method TimerTask.running?() - added:
method TimerTask.stop(*) - added:
method TimerTask.timeout_interval() - added:
method Transaction.abort() - added:
method Transaction.commit() - added:
method Transaction.read(_) - added:
method Transaction.unlock() - added:
method Transaction.valid?() - added:
method Transaction.write(_, _) - added:
method UnbufferedChannel.pop() - added:
method UnbufferedChannel.probe_set_size() - added:
method UnbufferedChannel.push(_) - added:
method UnbufferedChannel.remove_probe(_) - added:
method UnbufferedChannel.select(_) - added:
method WaitableList.delete(_) - added:
method WaitableList.empty?() - added:
method WaitableList.put(_) - added:
method WaitableList.size() - added:
method WaitableList.take() - added:
module Actress - added:
module Async - added:
module Channel - added:
module Executor - added:
module JavaExecutor - added:
module Logging - added:
module Observable - added:
module OptionsParser - added:
module RubyExecutor - added:
property Agent.operation_executor: reader - added:
property Agent.task_executor: reader - added:
property Configuration.logger: accessor - added:
property JavaThreadPoolExecutor.max_length: reader - added:
property JavaThreadPoolExecutor.max_queue: reader - added:
property JavaThreadPoolExecutor.overflow_policy: reader - added:
property RubyThreadPoolExecutor.completed_task_count: reader - added:
property RubyThreadPoolExecutor.idletime: reader - added:
property RubyThreadPoolExecutor.largest_length: reader - added:
property RubyThreadPoolExecutor.max_length: reader - added:
property RubyThreadPoolExecutor.max_queue: reader - added:
property RubyThreadPoolExecutor.min_length: reader - added:
property RubyThreadPoolExecutor.overflow_policy: reader - added:
property RubyThreadPoolExecutor.scheduled_task_count: reader - added:
protected method JavaExecutor.set_shutdown_hook() - added:
protected method MutexPriorityQueue.ordered?(_, _) - added:
protected method MutexPriorityQueue.sink(_) - added:
protected method MutexPriorityQueue.swap(_, _) - added:
protected method MutexPriorityQueue.swim(_) - added:
protected method RubyExecutor.execute(*) - added:
protected method RubyExecutor.init_executor() - added:
protected method RubyExecutor.kill_execution() - added:
protected method RubyExecutor.shutdown_execution() - added:
protected method RubySingleThreadExecutor.alive?() - added:
protected method RubySingleThreadExecutor.execute(*) - added:
protected method RubySingleThreadExecutor.kill_execution() - added:
protected method RubySingleThreadExecutor.new_worker_thread() - added:
protected method RubySingleThreadExecutor.shutdown_execution() - added:
protected method RubySingleThreadExecutor.supervise() - added:
protected method RubySingleThreadExecutor.work() - added:
protected method RubyThreadPoolExecutor.create_worker_thread() - added:
protected method RubyThreadPoolExecutor.drain_pool() - added:
protected method RubyThreadPoolExecutor.ensure_capacity?() - added:
protected method RubyThreadPoolExecutor.execute(*) - added:
protected method RubyThreadPoolExecutor.handle_overflow(*) - added:
protected method RubyThreadPoolExecutor.kill_execution() - added:
protected method RubyThreadPoolExecutor.prune_pool() - added:
protected method RubyThreadPoolExecutor.shutdown_execution() - added:
protected method TimerTask.deprecated(_, _, *) - added:
protected method TimerTask.kill_execution() - added:
protected method TimerTask.schedule_next_task(_ = …) - added:
protected method TimerTask.shutdown_execution() - added:
protected method TimerTask.timeout_task(_) - added:
protected property Observable.observers: accessor - added:
protected property RubyExecutor.mutex: reader - added:
protected property RubyExecutor.stop_event: reader - added:
protected property RubyExecutor.stopped_event: reader - added:
protected set Dereferenceable.value(_) - added:
set Async.executor(_) - added:
set Configuration.global_operation_pool(_) - added:
set Configuration.global_task_pool(_) - added:
set JavaAtomicBoolean.value(_) - added:
set MutexAtomic.value(_) - added:
set MutexAtomicBoolean.value(_) - added:
set TVar.unsafe_value(_) - added:
set TVar.value(_) - added:
static method Actress.current() - added:
static method Actress.experimental_acknowledged?() - added:
static method Actress.i_know_it_is_experimental!() - added:
static method Actress.spawn!(*) - added:
static method Actress.spawn(*) - added:
static method Actress.spawn_optionify(*) - added:
static method Async.validate_argc(_, _, *) - added:
static method Channel.select(*) - added:
static method JavaPriorityQueue.from_list(_, _ = …) - added:
static method MutexPriorityQueue.from_list(_, _ = …) - added:
static method PerThreadExecutor.post(*) - added:
static method TimerSet.calculate_schedule_time(_, _ = …) - added:
static method TimerTask.execute(_ = …) - added:
static method TimerTask.run!(*) - added:
static method Transaction.current() - added:
static set Transaction.current(_)
- added:
class ActressTerminated < Error - added:
class AdHoc - added:
class Core - added:
class Envelope - added:
class Error < StandardError - added:
class ROOT < Core.new(parent: nil, name: '/', class: Root) - added:
class Reference - added:
class Root - added:
constructor ActressTerminated(_) - added:
constructor AdHoc(*) - added:
constructor Core(_ = …) - added:
constructor Envelope(_, _, _, _) - added:
constructor Reference(_) - added:
method AdHoc.on_message(_) - added:
method Context.children() - added:
method Context.log(_, _, _ = …) - added:
method Context.on_envelope(_) - added:
method Context.on_message(_) - added:
method Context.spawn(*) - added:
method Context.terminate!() - added:
method Core.add_child(_) - added:
method Core.children() - added:
method Core.guard!() - added:
method Core.on_envelope(_) - added:
method Core.parent() - added:
method Core.remove_child(_) - added:
method Core.terminate!() - added:
method Core.terminated?() - added:
method CoreDelegations.actor_class() - added:
method CoreDelegations.actress_class() - added:
method CoreDelegations.executor() - added:
method CoreDelegations.name() - added:
method CoreDelegations.parent() - added:
method CoreDelegations.path() - added:
method CoreDelegations.ref() - added:
method CoreDelegations.reference() - added:
method CoreDelegations.terminated() - added:
method CoreDelegations.terminated?() - added:
method Envelope.address_path() - added:
method Envelope.reject!(_) - added:
method Envelope.sender_path() - added:
method Reference.==(_) - added:
method Reference.ask!(_, _ = …) - added:
method Reference.ask(_, _ = …) - added:
method Reference.inspect() - added:
method Reference.message(_, _ = …) - added:
method Reference.tell(_) - added:
method Reference.to_s() - added:
method Root.on_message(_) - added:
method TypeCheck.Child!(_, *) - added:
method TypeCheck.Child?(_, *) - added:
method TypeCheck.Match!(_, *) - added:
method TypeCheck.Match?(_, *) - added:
method TypeCheck.Type!(_, *) - added:
method TypeCheck.Type?(_, *) - added:
module Context - added:
module CoreDelegations - added:
module TypeCheck - added:
property Context.core: reader - added:
property Core.actor_class: reader - added:
property Core.executor: reader - added:
property Core.name: reader - added:
property Core.path: reader - added:
property Core.reference: reader - added:
property Core.terminated: reader - added:
property Envelope.address: reader - added:
property Envelope.ivar: reader - added:
property Envelope.message: reader - added:
property Envelope.sender: reader
- added:
method ClassMethods.spawn!(_, *) - added:
method ClassMethods.spawn(_, *) - added:
module ClassMethods
- added:
class AsyncDelegator - added:
class AwaitDelegator - added:
constructor AsyncDelegator(_, _, _) - added:
constructor AwaitDelegator(_, _)
- removed:
class Worker - removed:
constructor Worker(_) - removed:
method Worker.dead?() - removed:
method Worker.idle?() - removed:
method Worker.idletime() - removed:
method Worker.kill() - removed:
method Worker.run(_ = …) - removed:
method Worker.signal(*) - removed:
method Worker.stop()
- added:
class Probe < Concurrent::IVar - added:
constructor Probe(_ = …, _ = …) - added:
method Probe.channel() - added:
method Probe.composite_value() - added:
method Probe.set_unless_assigned(_, _) - added:
method Probe.value()
- added:
class EMPTY < Object.new
- removed:
class Worker - removed:
constructor Worker(_, _) - removed:
method Worker.dead?() - removed:
method Worker.kill() - removed:
method Worker.run(_ = …)
- removed:
class LifecycleError < StandardError
- removed:
class SchedulingError < ArgumentError
- added:
class Job < Struct.new(:executor, :args, :block) - added:
method Job.call()
- removed:
class MaxRestartFrequencyError < StandardError
- added:
class ABORTED < Object.new - added:
class AbortError < StandardError - added:
class CURRENT_TRANSACTION < ThreadLocalVar.new(nil) - added:
class ReadLogEntry < Struct.new(:tvar, :version) - added:
class UndoLogEntry < Struct.new(:tvar, :value)