go_queue

README

go_queue

go_queue

package main

import (
	"fmt"

	"github.com/sun-moon-star-star/go_queue"
)

func main() {
	queue := go_queue.New()

	queue.Append("sun-moon-star-star")

	len := queue.Len()

	element := queue.Remove()
	queue.Done()

	elementString := element.(string)

	fmt.Println(len, elementString)
}

Documentation

Index

• type ConcurrentQueue
  • func NewConcurrentQueue() *ConcurrentQueue
  • func (q *ConcurrentQueue) Append(item interface{}) error
  • func (q *ConcurrentQueue) Back() interface{}
  • func (q *ConcurrentQueue) BackNoBlocked() interface{}
  • func (q *ConcurrentQueue) Front() interface{}
  • func (q *ConcurrentQueue) FrontNoBlocked() interface{}
  • func (q *ConcurrentQueue) Len() int
  • func (q *ConcurrentQueue) Remove() interface{}
  • func (q *ConcurrentQueue) RemoveNoBlocked() interface{}
  • func (q *ConcurrentQueue) SetMaxLen(maxLen int)
• type Queue
  • func New() *Queue
  • func (q *Queue) Append(item interface{}) error
  • func (q *Queue) Done()
  • func (q *Queue) Join()
  • func (q *Queue) Len() int
  • func (q *Queue) Remove() interface{}
  • func (q *Queue) SetMaxLen(maxLen int)

Types

type ConcurrentQueue

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

func NewConcurrentQueue

func NewConcurrentQueue() *ConcurrentQueue

func (*ConcurrentQueue) Append

func (q *ConcurrentQueue) Append(item interface{}) error

func (*ConcurrentQueue) Back

func (q *ConcurrentQueue) Back() interface{}

func (*ConcurrentQueue) BackNoBlocked

func (q *ConcurrentQueue) BackNoBlocked() interface{}

func (*ConcurrentQueue) Front

func (q *ConcurrentQueue) Front() interface{}

func (*ConcurrentQueue) FrontNoBlocked

func (q *ConcurrentQueue) FrontNoBlocked() interface{}

func (*ConcurrentQueue) Len

func (q *ConcurrentQueue) Len() int

func (*ConcurrentQueue) Remove

func (q *ConcurrentQueue) Remove() interface{}

func (*ConcurrentQueue) RemoveNoBlocked

func (q *ConcurrentQueue) RemoveNoBlocked() interface{}

func (*ConcurrentQueue) SetMaxLen

func (q *ConcurrentQueue) SetMaxLen(maxLen int)

type Queue

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

func New

func New() *Queue

func (*Queue) Append

func (q *Queue) Append(item interface{}) error

func (*Queue) Done

func (q *Queue) Done()

func (*Queue) Join

func (q *Queue) Join()

func (*Queue) Len

func (q *Queue) Len() int

func (*Queue) Remove

func (q *Queue) Remove() interface{}

func (*Queue) SetMaxLen

func (q *Queue) SetMaxLen(maxLen int)