Skip to content

Commit

Permalink
Update to fix concurrency count error
Browse files Browse the repository at this point in the history
  • Loading branch information
qrpike committed Apr 16, 2019
1 parent 481c2bd commit 7d77de4
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion process.go
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down

0 comments on commit 7d77de4

Please sign in to comment.