Change criteria of starting new dynamic worker

Author: knizhnik

bgwpool.c

@@ -205,7 +205,7 @@ void BgwPoolExecute(BgwPool* pool, void* work, size_t size)
             SpinLockAcquire(&pool->lock);
         } else {
             pool->pending += 1;
-			if (pool->active == pool->nWorkers) { 
+			if (pool->active + pool->pending > pool->nWorkers) { 
 				BgwStartExtraWorker(pool);				
 			}
 			if (pool->lastPeakTime == 0 && pool->active == pool->nWorkers && pool->pending != 0) {

tests2/docker-entrypoint.sh

@@ -59,7 +59,8 @@ if [ "$1" = 'postgres' ]; then
 			default_transaction_isolation = 'repeatable read'
             log_line_prefix = '%t: '
 
-			multimaster.workers = 16
+			multimaster.workers = 4
+			multimaster.max_workers = 16
 			multimaster.max_nodes = 3
 			multimaster.volkswagen_mode = 1
 			multimaster.queue_size=52857600