// Execute will execute the request in new goroutine (bypass the parallelism limit)
Execute will execute the request in new goroutine (bypass the parallelism limit)
// Execute will execute the request in new goroutine ( bypass the parallelism limit )
func (w *worker) Execute(ctx context.Context, req *Request) <-chan Response {
	ch := make(chan Response, 1)
	w.wg.Add(1)
	go func() {
		defer w.wg.Done()
		ch <- w.workDoCmd(ctx, req)
	}()
	return ch
}
func ( w * worker ) Execute ( ctx context . Context , req * Request ) <- chan Response { ch := make ( chan Response , 1 ) w . wg . Add ( 1 ) go func ( ) { defer w . wg . Done ( ) ch <- w . workDoCmd ( ctx , req ) } ( ) return ch }
Execute will execute the request in new goroutine (bypass the parallelism limit)
Execute will execute the request in new goroutine ( bypass the parallelism limit )