Documentation
¶
Overview ¶
Example ¶
var totalCounter int32
pool := Pool{
MaxWorkers: 1,
Op: func(req Request) error {
atomic.AddInt32(&totalCounter, 1)
return nil
},
}
pool.Initialize()
for counter := 0; counter < 5; counter++ {
pool.AddWork(TestRequest{})
}
// Poll is not usable after calling Join
if err := pool.Join(); err != nil {
log.Fatal(err)
}
Output:
Index ¶
Examples ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pool ¶
type Pool struct {
MaxWorkers int
Op func(Request) error
// contains filtered or unexported fields
}
Pool is a wrapper to manage a set of Workers efficiently
func (*Pool) ActiveCount ¶
ActiveCount is the count of the workers who are active and doing work
Source Files
Click to show internal directories.
Click to hide internal directories.