myqueue

Documentation

Index

• func TestChannelQueueFivePush(t *testing.T)
• func TestChannelQueueMultipleFivePush(t *testing.T)
• func TestChannelQueueNoPush(t *testing.T)
• func TestChannelQueueOnePush(t *testing.T)
• func TestChannelQueueRecursiveStop(t *testing.T)
• type ChannelQueue
  • func (cq *ChannelQueue) NotifyWaitAdded(fn func(q MyQueue))
  • func (cq *ChannelQueue) NotifyWaitDone(fn func(q MyQueue))
  • func (cq *ChannelQueue) Push(item interface{})
  • func (cq *ChannelQueue) Stop()
  • func (cq *ChannelQueue) Wait(fn func(a interface{}))
• type MyQueue
  • func MakeChannelQueue(qbufferSize ...int) MyQueue

Functions

func TestChannelQueueFivePush

func TestChannelQueueFivePush(t *testing.T)

func TestChannelQueueMultipleFivePush

func TestChannelQueueMultipleFivePush(t *testing.T)

func TestChannelQueueNoPush

func TestChannelQueueNoPush(t *testing.T)

func TestChannelQueueOnePush

func TestChannelQueueOnePush(t *testing.T)

func TestChannelQueueRecursiveStop

func TestChannelQueueRecursiveStop(t *testing.T)

Types

type ChannelQueue

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

func (*ChannelQueue) NotifyWaitAdded

func (cq *ChannelQueue) NotifyWaitAdded(fn func(q MyQueue))

func (*ChannelQueue) NotifyWaitDone

func (cq *ChannelQueue) NotifyWaitDone(fn func(q MyQueue))

func (*ChannelQueue) Push

func (cq *ChannelQueue) Push(item interface{})

func (*ChannelQueue) Stop

func (cq *ChannelQueue) Stop()

func (*ChannelQueue) Wait

func (cq *ChannelQueue) Wait(fn func(a interface{}))

type MyQueue

type MyQueue interface {
	NotifyWaitAdded(fn func(q MyQueue))
	NotifyWaitDone(fn func(q MyQueue))
	Wait(fn func(a interface{}))
	Stop()
	Push(a interface{})
}

func MakeChannelQueue

func MakeChannelQueue(qbufferSize ...int) MyQueue