MCPcopy Index your code
hub / github.com/kopia/kopia / NewQueue

Function NewQueue

internal/parallelwork/parallel_work_queue.go:169–174  ·  view source on GitHub ↗

NewQueue returns new parallel work queue.

()

Source from the content-addressed store, hash-verified

167
168// NewQueue returns new parallel work queue.
169func NewQueue() *Queue {
170 return &Queue{
171 queueItems: list.New(),
172 monitor: sync.NewCond(&sync.Mutex{}),
173 }
174}

Callers 8

TestProcessWithErrorFunction · 0.92
TestWaitForActiveWorkersFunction · 0.92
TestProgressCallbackFunction · 0.92
CleanupOldDataFunction · 0.92
ListBlobsMethod · 0.92
EntryFunction · 0.92

Calls

no outgoing calls

Tested by 5

TestProcessWithErrorFunction · 0.74
TestWaitForActiveWorkersFunction · 0.74
TestProgressCallbackFunction · 0.74