Class: ConcurrentSHM::Channel::Unbuffered::Empty

Inherits:

ConcurrentSHM::Channel::Unbuffered

• Object
• ConcurrentSHM::Channel
• ConcurrentSHM::Channel::Unbuffered
• ConcurrentSHM::Channel::Unbuffered::Empty

Defined in:

lib/concurrent-shm/channel.rb

Overview

An unbuffered channel with zero-width packets.

Class Method Summary

• .new(shm, offset: 0, autosize: true) ⇒ Object

  Allocates an unbuffered, zero-width channel.

Instance Method Summary

• #recv ⇒ nil

  Receive a zero-width packet over the channel.

• #send ⇒ nil

  Send a zero-width packet over the channel.

Methods inherited from ConcurrentSHM::Channel

#close

Class Method Details

.new(shm, offset: 0, autosize: true) ⇒ Object

Allocates an unbuffered, zero-width channel.

See Also:

• ConcurrentSHM::Channel.new

# File 'lib/concurrent-shm/channel.rb', line 18

def self.new(shm, offset: 0, autosize: true)
  alloc(shm, 2, offset: offset, autosize: autosize) do |body|
    @state = body[0].as_intptr
    @closed = body[1].as_intptr
  end
end

Instance Method Details

#recv ⇒ nil

Receive a zero-width packet over the channel. Blocks if there are no senders.

Returns:

• (nil)

# File 'lib/concurrent-shm/channel.rb', line 34

def recv
  do_recv
end

#send ⇒ nil

Send a zero-width packet over the channel. Blocks if there are no receivers.

Returns:

• (nil)

Raises:

• (ClosedWriteError) —

  if the channel is closed

# File 'lib/concurrent-shm/channel.rb', line 28

def send
  do_send
end