@abstract @!visibility private
# File lib/concurrent/edge/future.rb, line 979 def initialize(future, blocked_by_futures, countdown) initialize_blocked_by(blocked_by_futures) @Countdown = AtomicFixnum.new countdown super(future) @BlockedBy.each { |future| future.add_callback :pr_callback_notify_blocked, self } end
!visibility private for inspection only
# File lib/concurrent/edge/future.rb, line 1006 def blocked_by @BlockedBy end
# File lib/concurrent/edge/future.rb, line 1010 def inspect "#{to_s[0..-2]} blocked_by:[#{ blocked_by.map(&:to_s).join(', ')}]>" end
@api private
# File lib/concurrent/edge/future.rb, line 988 def on_done(future) countdown = process_on_done(future) completable = completable?(countdown) if completable on_completable(future) # futures could be deleted from blocked_by one by one here, but that would be too expensive, # it's done once when all are done to free the reference clear_blocked_by! end end
Generated with the Darkfish Rdoc Generator 2.