Lines Matching defs:task
47 verbose_print("creating task %s" % self.next_ident)
48 thread.start_new_thread(self.task, (self.next_ident,))
52 def task(self, ident):
55 verbose_print("task %s will run for %sus" % (ident, round(delay*1e6)))
57 verbose_print("task %s done" % ident)
117 def task():
123 thread.start_new_thread(task, ())
127 # Allow the task to finish.
133 wr = weakref.ref(task, lambda _: done.append(None))
134 del task
141 def task():
143 raise ValueError("task failed")
149 thread.start_new_thread(task, ())
152 self.assertEqual(str(cm.unraisable.exc_value), "task failed")
153 self.assertIs(cm.unraisable.object, task)
206 verbose_print("task %s will run for %sus" %
209 verbose_print("task %s entering %s" % (ident, i))
211 verbose_print("task %s leaving barrier" % ident)