Class: Farce::LFUMap

Inherits:
Abstract::LFUMap show all
Includes:
Shareable::Delegated
Defined in:
lib/farce/lfu_map.rb

Overview

A Ractor-shareable bounded map that evicts the least frequently used entry. Equal-frequency victims are selected by recency. Transfer modes apply to values. Individual reads and writes increment frequency. Observation does not.

Instance Method Summary collapse

Methods included from Shareable

#ractor_shareable?

Methods inherited from Abstract::BoundedMap

#[], #[]=, #clear, #compare_keys_by_identity?, #compare_values_by_identity?, #delete, #each, #each_key, #each_value, #fetch, #getkey, #key?, #keys, #max_size, #max_size=, #prune, #shift, #size, #store_if_absent, #values

Methods included from Abstract::DuplicableMap

#compact, #compact_blank, #deep_dup, #duplicable?, #except, #flatten, #invert, #merge, #reject, #reverse_merge, #select, #slice, #stringify_keys, #symbolize_keys, #to_proc, #transform_keys, #transform_values, #with_indifferent_access

Methods inherited from Abstract::Map

#[], #[]=, #as_extended_json, #as_json, #assert_valid_keys, #assoc, #bson_type, #clear, #compare_by_identity?, #compare_keys_by_identity?, #compare_values_by_identity?, #deconstruct_keys, #delete, #dig, #each, #each_key, #each_pair, #each_value, #empty?, #fetch, #fetch_values, #getkey, #has_key?, #key, #key?, #keys, #length, #rassoc, #size, #store, #store_if_absent, #to_a, #to_bson, #to_bson_normalized_value, #to_cbor, #to_h, #to_hash, #to_json, #to_msgpack, #to_query, #to_s, #value?, #values_at, #weak_keys?, #weak_values?

Constructor Details

#initialize(entries = nil, mode: :copy) ⇒ LFUMap

Valid modes are:

  • :copy - The value will be copied between Ractors. This is the default mode.
  • :make_shareable - The value will be made Ractor-shareable using Ractor.make_shareable.
  • :move - The value will be moved between Ractors. This saves memory compared to copying, and supports values that can't be copied but moved (like IO objects). However, the value will no longer be accessible on the Ractor that pushed it.
  • :mutable - A Mutable instance will be created for the value. This isn't done recursively and thus will fail for nested unshareable values.
  • :local - The value will be kept local to the Ractor that pushed it. Another ractor trying to receive it will get an error. Useful for usage contained within a single Ractor.
  • :proxy - The value will be wrapped in a Farce::Proxy that executes calls in the original Ractor.
  • :raise - An error will be raised if the value is not Ractor-shareable. Useful for enforcing shareability.
  • :dedup - The value will be deduplicated using Farce.dedup, then made Ractor-shareable. This may update and freeze the original. Already-shareable values pass through unchanged.
  • :shareable_copy - The value will be copied and the copy will be made Ractor-shareable.

Parameters:

  • entries (Hash, Array<Array(BasicObject, BasicObject)>, Abstract::Map, #each, nil) (defaults to: nil) —

    Optional initial entries. Entries are stored sequentially and may be evicted.

  • mode (Symbol) (defaults to: :copy) —

    The default value transfer mode.



16
17
18
19
 
# File 'lib/farce/lfu_map.rb', line 16

def initialize(entries = nil, mode: :copy, **)
  @manager = marshal_mode_manager(mode)
  super(entries, **)
end

Instance Method Details

#mode ⇒ Symbol

The default transfer mode for values.

Returns:

  • (Symbol) 


23
 
# File 'lib/farce/lfu_map.rb', line 23

def mode = @manager.mode

#shareable_keys? ⇒ true

Keys must be shareable, except equality-mode strings that can be snapshotted.

Returns:

  • (true) 


27
 
# File 'lib/farce/lfu_map.rb', line 27

def shareable_keys? = true

#shareable_values? ⇒ true

Values are stored in Ractor-shareable representations.

Returns:

  • (true) 


31
 
# File 'lib/farce/lfu_map.rb', line 31

def shareable_values? = true