From 2c78e93222cc9d3b88456175348e42f7f40c449b Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Tue, 6 Jul 2021 17:30:31 +0300 Subject: Rework ephemeral and binary heaps Implemented a sync.Cond for binary heap algo to save processor from spinning in the for loop and receiving nil Items until the Queue will be filled. Add num_pollers option to the configuration to specify number of pollers from the queue. Add Resume, ResumeAll, Stop, StopAll, PushBatch methods to the ephemeral. Remove map and use sync.Map in the ephemeral broker. Add protobuf schema. Signed-off-by: Valery Piashchynski --- tests/plugins/jobs/configs/.rr-jobs-init.yaml | 1 + 1 file changed, 1 insertion(+) (limited to 'tests') diff --git a/tests/plugins/jobs/configs/.rr-jobs-init.yaml b/tests/plugins/jobs/configs/.rr-jobs-init.yaml index d86a8ad8..c81ba6ef 100644 --- a/tests/plugins/jobs/configs/.rr-jobs-init.yaml +++ b/tests/plugins/jobs/configs/.rr-jobs-init.yaml @@ -22,6 +22,7 @@ sqs: jobs: + num_pollers: 32 # worker pool configuration pool: num_workers: 10 -- cgit v1.2.3