removing workers in runtime

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()
 }