Merge pull request #1 from siddhant2408/wp-1

vardius · web-flow · commit 3c1740fa3c14 · 2018-08-12T19:56:16.000+10:00
wp-1 removed defer
diff --git a/pool.go b/pool.go
@@ -20,10 +20,9 @@ type pool struct {
 }
 
 // Delegate job to a workers
+// will block if channel is full, you might want to wrap it with goroutine to avoid it
 func (p *pool) Delegate(args ...interface{}) {
-	go func() {
-		p.queue <- buildQueueValue(args)
-	}()
+	p.queue <- buildQueueValue(args)
 }
 
 // Start given number of workers that will take jobs from a queue

Original file line number	Diff line number	Diff line change
`@@ -20,10 +20,9 @@ type pool struct {`
`20`	`20`	`}`
`21`	`21`
`22`	`22`	`// Delegate job to a workers`
	`23`	`+// will block if channel is full, you might want to wrap it with goroutine to avoid it`
`23`	`24`	`func (p *pool) Delegate(args ...interface{}) {`
`24`		`- go func() {`
`25`		`- p.queue <- buildQueueValue(args)`
`26`		`- }()`
	`25`	`+ p.queue <- buildQueueValue(args)`
`27`	`26`	`}`
`28`	`27`
`29`	`28`	`// Start given number of workers that will take jobs from a queue`