diff options
Diffstat (limited to 'lib/Thread/Task/Manager.pm')
-rw-r--r-- | lib/Thread/Task/Manager.pm | 11 |
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); |