Lines Matching refs:threads

80         (buffer_, rw_lock, threads) = self.__init_variables()
82         threads.append(Reader(buffer_, rw_lock, 0, 0))
83         threads.append(Writer(buffer_, rw_lock, 0.2, 0.4, 1))
84         threads.append(Reader(buffer_, rw_lock, 0.3, 0.3))
85         threads.append(Reader(buffer_, rw_lock, 0.5, 0))
87         self.__start_and_join_threads(threads)
94         self.assertEqual([], threads[0].buffer_read)
95         self.assertEqual([1], threads[2].buffer_read)
96         self.assertEqual([1], threads[3].buffer_read)
97         self.assert_(threads[1].exit_time <= threads[2].entry_time)
98         self.assert_(threads[2].entry_time <= threads[3].entry_time)
99         self.assert_(threads[3].exit_time < threads[2].exit_time)
102         (buffer_, rw_lock, threads) = self.__init_variables()
104         threads.append(Writer(buffer_, rw_lock, 0, 0.4, 1))
105         threads.append(Writer(buffer_, rw_lock, 0.1, 0, 2))
106         threads.append(Reader(buffer_, rw_lock, 0.2, 0))
108         self.__start_and_join_threads(threads)
112         self.assertEqual([1, 2], threads[2].buffer_read)
113         self.assert_(threads[0].exit_time <= threads[1].entry_time)
114         self.assert_(threads[1].exit_time <= threads[2].exit_time)
117         (buffer_, rw_lock, threads) = self.__init_variables()
119         threads.append(Writer(buffer_, rw_lock, 0, 0, 1))
120         threads.append(Reader(buffer_, rw_lock, 0.1, 0.4))
121         threads.append(Writer(buffer_, rw_lock, 0.2, 0, 2))
122         threads.append(Reader(buffer_, rw_lock, 0.3, 0))
123         threads.append(Reader(buffer_, rw_lock, 0.3, 0))
125         self.__start_and_join_threads(threads)
129         self.assertEqual([1], threads[1].buffer_read)
130         self.assertEqual([1, 2], threads[3].buffer_read)
131         self.assertEqual([1, 2], threads[4].buffer_read)
132         self.assert_(threads[0].exit_time < threads[1].entry_time)
133         self.assert_(threads[1].exit_time <= threads[2].entry_time)
134         self.assert_(threads[2].exit_time <= threads[3].entry_time)
135         self.assert_(threads[2].exit_time <= threads[4].entry_time)
138         (buffer_, rw_lock, threads) = self.__init_variables()
140         threads.append(Writer(buffer_, rw_lock, 0, 0, 1))
141         threads.append(Reader(buffer_, rw_lock, 0.1, 0.6))
142         threads.append(Writer(buffer_, rw_lock, 0.2, 0.1, 2))
143         threads.append(Reader(buffer_, rw_lock, 0.3, 0))
144         threads.append(Reader(buffer_, rw_lock, 0.4, 0))
145         threads.append(Writer(buffer_, rw_lock, 0.5, 0.1, 3))
147         self.__start_and_join_threads(threads)
152         self.assertEqual([1], threads[1].buffer_read)
153         self.assertEqual([1, 2, 3], threads[3].buffer_read)
154         self.assertEqual([1, 2, 3], threads[4].buffer_read)
155         self.assert_(threads[0].exit_time < threads[1].entry_time)
156         self.assert_(threads[1].exit_time <= threads[2].entry_time)
157         self.assert_(threads[1].exit_time <= threads[5].entry_time)
158         self.assert_(threads[2].exit_time <= threads[3].entry_time)
159         self.assert_(threads[2].exit_time <= threads[4].entry_time)
160         self.assert_(threads[5].exit_time <= threads[3].entry_time)
161         self.assert_(threads[5].exit_time <= threads[4].entry_time)
167         threads = []
168         return (buffer_, rw_lock, threads)
171     def __start_and_join_threads(threads):  argument
172         for t in threads:
174         for t in threads: