diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-18 11:37:39 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-18 11:37:39 +0300 |
| commit | 978451159855c155b2aecdca3c86f47e5c6dd1ff (patch) | |
| tree | a21ce19ccc4cc66d78a3460e10bbd3c64175752c /pkg | |
| parent | 9c51360f9119a4114bdcc21c8e61f0908a3c876d (diff) | |
Remove channel from the Queue
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/worker_watcher/container/queue/queue.go | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/pkg/worker_watcher/container/queue/queue.go b/pkg/worker_watcher/container/queue/queue.go index a792d7c1..4f611bbe 100644 --- a/pkg/worker_watcher/container/queue/queue.go +++ b/pkg/worker_watcher/container/queue/queue.go @@ -26,18 +26,15 @@ type Queue struct { head *Node tail *Node - recvCh chan worker.BaseProcess - curr uint64 - len uint64 + curr uint64 + len uint64 sliceSize uint64 } func NewQueue() *Queue { q := &Queue{ - mu: sync.Mutex{}, - // w/o buffering - recvCh: make(chan worker.BaseProcess), + mu: sync.Mutex{}, head: nil, tail: nil, curr: 0, |