Searched refs:checkedThread (Results 1 – 23 of 23) sorted by relevance
113 self.checkedThread(144 threads = [self.checkedThread(target=dequeue) for _ in enqueue_ops]184 enqueue_thread = self.checkedThread(target=enqueue)185 dequeue_thread = self.checkedThread(target=dequeue)453 threads = [self.checkedThread(target=enqueue) for _ in range(10)]477 threads = [self.checkedThread(target=dequeue) for _ in range(10)]500 threads = [self.checkedThread(target=dequeue) for _ in range(10)]528 threads.append(self.checkedThread(target=dequeue, args=(dequeue_op,)))553 enqueue_thread = self.checkedThread(target=enqueue)554 dequeue_thread = self.checkedThread(target=dequeue)[all …]
137 self.checkedThread(171 threads = [self.checkedThread(target=dequeue) for _ in enqueue_ops]215 enqueue_thread = self.checkedThread(target=enqueue)216 dequeue_thread = self.checkedThread(target=dequeue)654 threads = [self.checkedThread(target=enqueue) for _ in range(10)]680 threads = [self.checkedThread(target=dequeue) for _ in range(10)]707 threads = [self.checkedThread(target=dequeue) for _ in range(10)]734 enqueue_threads = [self.checkedThread(target=enqueue) for _ in range(10)]735 dequeue_threads = [self.checkedThread(target=dequeue) for _ in range(10)]766 dequeue_thread = self.checkedThread(target=dequeue)[all …]
790 self.checkedThread(824 threads = [self.checkedThread(target=dequeue) for _ in enqueue_ops]854 enqueue_thread = self.checkedThread(target=enqueue)855 dequeue_thread = self.checkedThread(target=dequeue)877 thread = self.checkedThread(target=blocking_dequeue)906 thread = self.checkedThread(target=blocking_enqueue)964 self.checkedThread(966 self.checkedThread(968 self.checkedThread(970 self.checkedThread([all …]
53 self.checkedThread(83 self.checkedThread(119 self.checkedThread(150 self.checkedThread(
95 self.checkedThread(154 self.checkedThread(158 self.checkedThread(210 self.checkedThread(214 self.checkedThread(259 self.checkedThread(
419 self.checkedThread(449 apply_grad_thread = self.checkedThread(target=apply_grad)456 threads = [self.checkedThread(target=take_grad) for _ in range(10)]492 accum_thread = self.checkedThread(target=apply_grad)493 takeg_thread = self.checkedThread(target=take_grad)512 takeg_thread = self.checkedThread(
289 self.checkedThread(327 self.checkedThread(target=apply_indexed_slices_grad, args=(o,))365 apply_indexed_slices_grad_thread = self.checkedThread(372 threads = [self.checkedThread(target=take_grad) for _ in range(10)]412 accum_thread = self.checkedThread(target=apply_indexed_slices_grad)413 takeg_thread = self.checkedThread(target=take_grad)437 takeg_thread = self.checkedThread(
303 t = self.checkedThread(target=take)347 self.checkedThread(351 self.checkedThread(556 self.checkedThread(560 self.checkedThread(656 self.checkedThread(660 self.checkedThread(664 self.checkedThread(
84 self.checkedThread(target=enqueue, args=(e,)) for e in enqueue_ops114 threads = [self.checkedThread(target=dequeue) for _ in enqueue_ops]155 enqueue_thread = self.checkedThread(target=enqueue)156 dequeue_thread = self.checkedThread(target=dequeue)
163 self.checkedThread(166 self.checkedThread(237 thread_0 = self.checkedThread(239 thread_1 = self.checkedThread(
168 blocking_thread = self.checkedThread(blocking_dequeue)
50 self.checkedThread(target=thread_fn, args=(i,))
71 thread = self.checkedThread(self.assert_op_cancelled, args=(get_next(),))
247 thread = self.checkedThread(self.assert_op_cancelled, args=(result,))
213 threads = [self.checkedThread(target=iterator_thread) for _ in range(8)]304 threads = [self.checkedThread(target=iterator_thread) for _ in range(64)]1198 thread = self.checkedThread(self.assert_op_cancelled, args=(get_next(),))
197 self.checkedThread(consumer_thread) for _ in range(num_threads)231 self.checkedThread(consumer_thread) for _ in range(num_threads)
58 thread = self.checkedThread(self.assert_op_cancelled, args=(get_next(),))
271 thread = self.checkedThread(
207 t = self.checkedThread(target=noop, args=(event_arg,))218 t = self.checkedThread(target=err_func)231 t = self.checkedThread(target=err_func)244 self.checkedThread(
2487 def checkedThread(self, target, args=None, kwargs=None): member in TensorFlowTestCase
1132 t = self.checkedThread(1154 threads = [self.checkedThread(target=run_step) for _ in range(100)]1192 threads = [self.checkedThread(target=run_loop) for _ in range(10)]1213 run_threads = [self.checkedThread(target=run_loop) for _ in range(10)]1217 build_threads = [self.checkedThread(target=SessionTest._build_graph)
370 t = self.checkedThread(cancel_thread)
3437 t = self.checkedThread(cancel_thread)