From 7d77de40b0276b1610c8fcdec8aea2aaa31f46d7 Mon Sep 17 00:00:00 2001 From: Quinton Pike Date: Mon, 15 Apr 2019 21:38:09 -0400 Subject: [PATCH] Update to fix concurrency count error --- process.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/process.go b/process.go index 22da405..2232aeb 100644 --- a/process.go +++ b/process.go @@ -66,7 +66,7 @@ func ( p *Processor ) requestErrandToProcess(){ func ( p *Processor ) Run(){ ticker := time.NewTicker( 4 * time.Second ) // Create the actually processor threads: - for i := 0; i < p.Concurrency; i++ { + for i := 1; i <= p.Concurrency; i++ { obj := p.NewProcThread() p.Procs = append( p.Procs, obj ) go obj.RunThread()