Class: Farce::Unshared::TimerQueue

Inherits:
Abstract::TimerQueue show all
Includes:
Farce::Unshareable, Internal::UnsharedQueueWaiting
Defined in:
lib/farce/unshared/timer_queue.rb

Overview

A timer queue that stores and returns values directly.

Instance Attribute Summary

Attributes inherited from Abstract::Queue

#capacity, #num_waiting, #size

Instance Method Summary collapse

Methods included from Farce::Unshareable

#initialize, #ractor_shareable?

Methods inherited from Abstract::TimerQueue

#delete, #first_timestamp, #initialize, #last_timestamp, #overdue?, #overdue_by, #peek, #pop, #push, #try_pop, #try_push, #wait_pop

Methods inherited from Abstract::Queue

#age_tracking?, #clear, #close, #closed?, #deq, #duplicable?, #empty?, #enq, #full?, #generation, #initialize, #length, #max, #oldest_age, #oldest_enqueued_at, #pop, #push, #seal, #sealed?, #try_pop, #try_push, #wait_pop, #wait_push

Instance Method Details

#mode ⇒ Symbol

Returns always returns :local.

Returns:

  • (Symbol) —

    always returns :local



13
# File 'lib/farce/unshared/timer_queue.rb', line 13

def mode = :local