summaryrefslogtreecommitdiff
path: root/pool.go
diff options
context:
space:
mode:
Diffstat (limited to 'pool.go')
-rw-r--r--pool.go7
1 files changed, 3 insertions, 4 deletions
diff --git a/pool.go b/pool.go
index 8372b4a6..2e59e154 100644
--- a/pool.go
+++ b/pool.go
@@ -22,10 +22,6 @@ 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{}))
@@ -35,6 +31,9 @@ type Pool interface {
// Workers returns worker list associated with the pool.
Workers() (workers []*Worker)
+ // Remove forces pool to destroy specific worker.
+ Remove(w *Worker, err error)
+
// Destroy all underlying workers (but let them to complete the task).
Destroy()
}