Lines Matching refs:threads
52 threads = qr.create_threads(sess)
53 self.assertEqual(sorted(t.name for t in threads),
55 for t in threads:
57 for t in threads:
73 threads = qr.create_threads(sess)
74 self.assertEqual(sorted(t.name for t in threads),
78 for t in threads:
80 for t in threads:
91 threads = qr.create_threads(sess)
93 for t in threads:
95 for t in threads:
111 threads = qr.create_threads(sess)
112 for t in threads:
119 for t in threads:
143 threads = qr.create_threads(sess, coord)
144 self.assertEqual(sorted(t.name for t in threads),
147 for t in threads:
159 threads = qr.create_threads(sess, coord)
160 for t in threads:
193 # NOTE that this test does not actually start the threads.
194 threads = qr.create_threads(sess, coord=coord)
196 self.assertEqual(len(threads), len(other_threads))
208 threads = []
209 # NOTE that this test does not actually start the threads.
210 threads.extend(qr.create_threads(sess, coord=coord))
224 threads = qr.create_threads(sess, start=True)
225 self.assertEqual(sorted(t.name for t in threads),
228 for t in threads:
234 threads = qr.create_threads(sess, start=True)
235 for t in threads:
261 threads = queue_runner_impl.start_queue_runners(sess)
262 for t in threads:
291 threads = queue_runner_impl.start_queue_runners(
293 self.assertFalse(threads)
308 threads = queue_runner_impl.start_queue_runners(sess)
309 for t in threads:
