Function newQueue

protocols/cpc/syncer/queue.go:31–37

(size int)

}

func newQueue(size int) *queue {
	return &queue{
		queue: make(chan resultTask, size),
		size:  0,
		limit: int32(size),
	}
}

func (q *queue) get() (resultTask, error) {
	timer := time.NewTimer(1 * time.Second)