continuesqueue

package module

v1.1.1 Latest Latest Go to latest Published: Aug 15, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Queue continues queue

func NewQueue(buckets int, cap int, generator generatorFn) *Queue

NewQueue returns a Queue pointer

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

Dequeue dequeue element retry if pool locked

func (q *Queue) DequeueWithTimeout(timeout time.Duration) (interface{}, error)

DequeueWithTimeout .

func (q *Queue) EnqueueEqually()

func (q *Queue) Fill(list []interface{})

func (q *Queue) Iter() <-chan interface{}

Iter iterate elements in the queue

func (q *Queue) SetFillThreshold(n int)