try without mutexes

Author: skudasov

wasp/wasp.go

@@ -257,7 +257,6 @@ type Generator struct {
 	dataCancel         context.CancelFunc
 	gun                Gun
 	vu                 VirtualUser
-	vusMu              *sync.Mutex
 	vus                []VirtualUser
 	ResponsesChan      chan *Response
 	Responses          *Responses
@@ -321,7 +320,6 @@ func NewGenerator(cfg *Config) (*Generator, error) {
 		dataCancel:         dataCancel,
 		gun:                cfg.Gun,
 		vu:                 cfg.VU,
-		vusMu:              &sync.Mutex{},
 		Responses:          NewResponses(rch),
 		ResponsesChan:      rch,
 		labels:             ls,
@@ -381,9 +379,7 @@ func (g *Generator) runExecuteLoop() {
 		for i := 0; i < int(vus); i++ {
 			inst := g.vu.Clone(g)
 			g.runVU(inst)
-			g.vusMu.Lock()
 			g.vus = append(g.vus, inst)
-			g.vusMu.Unlock()
 		}
 	}
 }
@@ -512,7 +508,6 @@ func (g *Generator) processSegment() bool {
 		if oldVUs == newVUs {
 			return false
 		}
-		g.vusMu.Lock()
 		if oldVUs > g.currentSegment.From {
 			for i := 0; i < vusToSpawn; i++ {
 				g.vus[i].Stop(g)
@@ -525,7 +520,6 @@ func (g *Generator) processSegment() bool {
 				g.vus = append(g.vus, inst)
 			}
 		}
-		g.vusMu.Unlock()
 	}
 	return false
 }