mirror
/
ants
mirror of https://github.com/panjf2000/ants.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

update

This commit is contained in:
Andy Pan 2018-07-08 10:38:40 +08:00
parent 2e7d823141
commit 5aa4fd3b9d
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pool_func.go
View File

@ -63,8 +63,9 @@ type PoolWithFunc struct {
} }
func (p *PoolWithFunc) monitorAndClear() { func (p *PoolWithFunc) monitorAndClear() {
heartbeat := time.NewTicker(p.expiryDuration)
go func() { go func() {
for { for range heartbeat.C {
time.Sleep(p.expiryDuration) time.Sleep(p.expiryDuration)
currentTime := time.Now() currentTime := time.Now()
p.lock.Lock() p.lock.Lock()
@ -88,12 +89,12 @@ func (p *PoolWithFunc) monitorAndClear() {
}() }()
} }
// NewTimingPoolWithFunc generates a instance of ants pool with a specific function and a custom timed task // NewPoolWithFunc generates a instance of ants pool with a specific function
func NewPoolWithFunc(size int, f pf) (*PoolWithFunc, error) { func NewPoolWithFunc(size int, f pf) (*PoolWithFunc, error) {
return NewTimingPoolWithFunc(size, DefaultCleanIntervalTime, f) return NewTimingPoolWithFunc(size, DefaultCleanIntervalTime, f)
} }
// NewPoolWithFunc generates a instance of ants pool with a specific function // NewTimingPoolWithFunc generates a instance of ants pool with a specific function and a custom timed task
func NewTimingPoolWithFunc(size, expiry int, f pf) (*PoolWithFunc, error) { func NewTimingPoolWithFunc(size, expiry int, f pf) (*PoolWithFunc, error) {
if size <= 0 { if size <= 0 {
return nil, ErrPoolSizeInvalid return nil, ErrPoolSizeInvalid