fastchan

README

fast-chan

Based on Gringo and compatible with Gotemplate

Benchmarks work best on GOMAXPROCS=1. In real world usage, this might have to be experimented with

This is created and optimized for SPSC case and might blow up for multiple producers and/or multiple consumers

Documentation

Index

• type CacheItem
• type FastChan
  • func NewFastChan(size uint64) *FastChan
  • func (c *FastChan) Empty()
  • func (c *FastChan) IsEmpty() bool
  • func (c *FastChan) IsFull() bool
  • func (c *FastChan) Put(value CacheItem)
  • func (c *FastChan) Read() CacheItem
  • func (c *FastChan) Size() uint64

Types

type CacheItem

type CacheItem interface{}

template type FastChan(CacheItem)

type FastChan

type FastChan struct {
	// contains filtered or unexported fields
}

FastChan is a minimalist queue replacement for channels with higher throughput

func NewFastChan

func NewFastChan(size uint64) *FastChan

NewFastChan creates a new channel

func (*FastChan) Empty

func (c *FastChan) Empty()

Empty the channel

func (*FastChan) IsEmpty

func (c *FastChan) IsEmpty() bool

IsEmpty checks if the channel is empty

func (*FastChan) IsFull

func (c *FastChan) IsFull() bool

IsFull checks if the channel is full

func (*FastChan) Put

func (c *FastChan) Put(value CacheItem)

Put writes a CacheItem to the front of the channel

func (*FastChan) Read

func (c *FastChan) Read() CacheItem

Read reads and removes a CacheItem from the back of the channel

func (*FastChan) Size

func (c *FastChan) Size() uint64

Size gets the size of the contents in the channel buffer