Skip to content

Commit 5733a8f

Browse files
committed
Only use boost workers for leveldb shadow queues
The leveldb shadow queue of a persistable channel queue should always start with 0 workers and just use boost to add additional workers if necessary. Signed-off-by: Andrew Thornton <[email protected]>
1 parent ae6d786 commit 5733a8f

File tree

2 files changed

+8
-8
lines changed

2 files changed

+8
-8
lines changed

modules/queue/queue_disk_channel.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,10 +75,10 @@ func NewPersistableChannelQueue(handle HandlerFunc, cfg, exemplar interface{}) (
7575
BatchLength: config.BatchLength,
7676
BlockTimeout: 1 * time.Second,
7777
BoostTimeout: 5 * time.Minute,
78-
BoostWorkers: 5,
79-
MaxWorkers: 6,
78+
BoostWorkers: 1,
79+
MaxWorkers: 5,
8080
},
81-
Workers: 1,
81+
Workers: 0,
8282
Name: config.Name + "-level",
8383
},
8484
DataDir: config.DataDir,

modules/queue/unique_queue_disk_channel.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -73,12 +73,12 @@ func NewPersistableChannelUniqueQueue(handle HandlerFunc, cfg, exemplar interfac
7373
WorkerPoolConfiguration: WorkerPoolConfiguration{
7474
QueueLength: config.QueueLength,
7575
BatchLength: config.BatchLength,
76-
BlockTimeout: 0,
77-
BoostTimeout: 0,
78-
BoostWorkers: 0,
79-
MaxWorkers: 1,
76+
BlockTimeout: 1 * time.Second,
77+
BoostTimeout: 5 * time.Minute,
78+
BoostWorkers: 1,
79+
MaxWorkers: 5,
8080
},
81-
Workers: 1,
81+
Workers: 0,
8282
Name: config.Name + "-level",
8383
},
8484
DataDir: config.DataDir,

0 commit comments

Comments
 (0)