Skip to content

Commit

Permalink
Changes comments
Browse files Browse the repository at this point in the history
  • Loading branch information
kc596 committed Nov 1, 2020
1 parent a8d8c89 commit 9b955da
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions pool.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"sync"
)

// Worker Pool Type
// Pool is type for Worker Pool
type Pool struct {
name string
workers chan int
Expand All @@ -19,7 +19,7 @@ type Pool struct {
* Worker Pool APIs
***************************************************************************/

// Creates a new worker pool to manage goroutines
// New creates a new worker pool to manage goroutines
func New(name string, workers int, panicHandler func(alias string, err interface{})) *Pool {
pool := &Pool{
name: name,
Expand Down Expand Up @@ -47,7 +47,7 @@ func (pool *Pool) Submit(job func(), priority float64) {
pool.wg.Add(1)
}

// Returns waitgroup to wait for all jobs submitted to finish
// WaitGroup to wait for all jobs submitted to finish
// WARNING: would not wait if there are no jobs at the instant
func (pool *Pool) WaitGroup() *sync.WaitGroup {
return pool.wg
Expand Down

0 comments on commit 9b955da

Please sign in to comment.