diff options
| -rw-r--r-- | pool.go | 4 | ||||
| -rw-r--r-- | static_pool.go | 5 |
2 files changed, 7 insertions, 2 deletions
@@ -22,6 +22,10 @@ const ( // Pool managed set of inner worker processes. type Pool interface { + // Watch enables worker watching (to destroy expired workers or workers which experience + // memory leaks). + Watch(w Watcher) + // Listen all caused events to attached watcher. Listen(l func(event int, ctx interface{})) diff --git a/static_pool.go b/static_pool.go index 336ae520..69edfd35 100644 --- a/static_pool.go +++ b/static_pool.go @@ -81,8 +81,9 @@ func NewPool(cmd func() *exec.Cmd, factory Factory, cfg Config) (*StaticPool, er return p, nil } -// WatchWorkers enables worker watching. -func (p *StaticPool) WatchWorkers(w Watcher) { +// Watch enables worker watching (to destroy expired workers or workers which experience +// memory leaks). +func (p *StaticPool) Watch(w Watcher) { p.mul.Lock() defer p.mul.Unlock() |