summaryrefslogtreecommitdiff
path: root/lib/Thread/Task/Manager.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/Thread/Task/Manager.pm')
-rw-r--r--lib/Thread/Task/Manager.pm11
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);