Channels

In this example, we use the Channel frontend to exchange tokens between one/multiple producer(s) and a single consumer. This example is implemented with two backends:

• include/producer.hpp contains the semantics for the producer(s)

• include/consumer.hpp contains the semantics for the consumer

• source/ contains variants of the main program implemented under different backends

  • lpf.cpp corresponds to the LPF backend implementation

  • mpi.cpp corresponds to the MPI backend implementation

Both the producer and consumer functions receive an instance of the HiCR::L1::MemoryManager, for the allocation of the token and coordination buffer(s), and; an instance of HiCR::L1::CommunicationManager, for the communication of tokens between the HICR instances.

Instantiate channels has more on allocating memory slots, making them globally available, and create channels.

For details on each example, choose one of the following:

• Channels: Fixed-size
  • Channels: Fixed-Size MPSC
    • Channels: Fixed-Size MPSC locking
      • Push tokens
      • Receive tokens
    • Channels: Fixed-Size MPSC non-locking
  • Channels: Fixed-Size SPSC
    • Push tokens
    • Receive tokens
• Channels: Variable-Size
  • Channels: Variable-Size MPSC
    • Channels: Variable-Size MPSC locking
      • Push tokens
      • Receive tokens
    • Channels: Variable-Size MPSC non-locking
  • Channels: Variable-Size SPSC