Method empty

protocols/cpc/syncer/queue.go:59–61

()

}

func (q *queue) empty() bool {
	return atomic.LoadInt32(&q.size) == 0
}

func (q *queue) clear() {
	for !q.empty() {