From 92ec1b2845f66c91af683f884924b74cd909ecd8 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Fri, 29 Jan 2021 14:31:28 +0000 Subject: [PATCH] Workers --- syncapi/streams/stream_pdu.go | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/syncapi/streams/stream_pdu.go b/syncapi/streams/stream_pdu.go index 0d2378f14..220629cfb 100644 --- a/syncapi/streams/stream_pdu.go +++ b/syncapi/streams/stream_pdu.go @@ -11,8 +11,8 @@ import ( "go.uber.org/atomic" ) -const COMPLETE_SYNC_QUEUE = 2048 -const COMPLETE_SYNC_WORKERS = 256 +const PDU_STREAM_QUEUESIZE = 2048 +const PDU_STREAM_WORKERS = 256 type PDUStreamProvider struct { StreamProvider @@ -34,17 +34,16 @@ func (p *PDUStreamProvider) worker() { } func (p *PDUStreamProvider) queue(f func()) { - p.tasks <- f - if p.workers.Load() < COMPLETE_SYNC_WORKERS { + if p.workers.Load() < PDU_STREAM_WORKERS { p.workers.Inc() go p.worker() } + p.tasks <- f } func (p *PDUStreamProvider) Setup() { p.StreamProvider.Setup() - - p.tasks = make(chan func(), COMPLETE_SYNC_QUEUE) + p.tasks = make(chan func(), PDU_STREAM_QUEUESIZE) p.latestMutex.Lock() defer p.latestMutex.Unlock()