test for TT::Manager & signalingHEADmaster

1 files changed, 4 insertions, 7 deletions

diff --git a/lib/Thread/Task/Manager.pm b/lib/Thread/Task/Manager.pm
index 1410799..14f6963 100644
--- a/lib/Thread/Task/Manager.pm
+++ b/lib/Thread/Task/Manager.pm
@@ -49,7 +49,6 @@ class Thread::Task::Manager {
             _workers_count => 'count',
             _set_worker => 'set',
             _get_worker => 'get',
-            _delete_worker => 'delete',
             _workers => 'elements',
         },
     );
@@ -64,7 +63,6 @@ class Thread::Task::Manager {
             _set_handle => 'set',
             _get_handle => 'get',
             _delete_handle => 'delete',
-            _handles => 'elements',
         },
     );
 
@@ -74,11 +72,9 @@ class Thread::Task::Manager {
         default => sub { {} },
         init_arg => undef,
         handles => {
-            _running_count => 'count',
             _set_running => 'set',
             _get_running => 'get',
             _delete_running => 'delete',
-            _running => 'elements',
         },
     );
 
@@ -99,7 +95,7 @@ class Thread::Task::Manager {
         does => Conduit_T,
     );
 
-    method BUILD() {
+    method BUILD(HashRef $params) {
         $self->conduit->conduit_init($self);
     }
 
@@ -131,7 +127,8 @@ class Thread::Task::Manager {
     }
 
     method stop_thread(Int $worker_id) {
-        $self->_delete_worker($worker_id)->stop;
+        my $worker=$self->_get_worker($worker_id);
+        $worker->stop;
     }
 
     method next_thread() {
@@ -173,7 +170,7 @@ class Thread::Task::Manager {
 
         my $worker = $self->next_thread or return;
         $worker->hid($hid);
-        $handle->wid($worker->wid);
+        #$handle->wid($worker->wid);
 
         $worker->send(task => $handle->as_array);