|
5 | 5 | import queue |
6 | 6 | except ImportError: # python 2.x compatibility |
7 | 7 | import Queue as queue |
8 | | -from creational.pool import QueueObject |
| 8 | +from creational.pool import ObjectPool |
9 | 9 |
|
10 | 10 |
|
11 | 11 | class TestPool(unittest.TestCase): |
12 | 12 |
|
13 | 13 | def setUp(self): |
14 | | - |
15 | | - def test_object(queue): |
16 | | - queue_object = QueueObject(queue, True) |
17 | | - print('Inside func: {}'.format(queue_object.object)) |
18 | | - |
19 | | - def test_pool_behavior(self): |
20 | | - sample_queue = queue.Queue() |
21 | | - sample_queue.put('yam') |
22 | | - self.assertTrue(sample_queue.get() == 'yam') |
23 | | - # with QueueObject(sample_queue) as obj: |
24 | | - # print('Inside with: {}'.format(obj)) |
25 | | - |
26 | | -# sample_queue.put('sam') |
27 | | -# test_object(sample_queue) |
28 | | -# print('Outside func: {}'.format(sample_queue.get())) |
29 | | - |
30 | | -# if not sample_queue.empty(): |
31 | | -# print(sample_queue.get()) |
32 | | - |
33 | | - |
34 | | -# if __name__ == '__main__': |
35 | | -# main() |
36 | | - |
37 | | -### OUTPUT ### |
38 | | -# Inside with: yam |
39 | | -# Outside with: yam |
40 | | -# Inside func: sam |
41 | | -# Outside func: sam |
42 | | - |
| 14 | + self.sample_queue = queue.Queue() |
| 15 | + self.sample_queue.put('first') |
| 16 | + self.sample_queue.put('second') |
| 17 | + |
| 18 | + def test_items_recoil(self): |
| 19 | + with ObjectPool(self.sample_queue, True) as pool: |
| 20 | + self.assertEqual(pool, 'first') |
| 21 | + self.assertTrue(self.sample_queue.get() == 'second') |
| 22 | + self.assertFalse(self.sample_queue.empty()) |
| 23 | + self.assertTrue(self.sample_queue.get() == 'first') |
| 24 | + self.assertTrue(self.sample_queue.empty()) |
| 25 | + |
| 26 | + def test_frozen_pool(self): |
| 27 | + with ObjectPool(self.sample_queue) as pool: |
| 28 | + self.assertEqual(pool, 'first') |
| 29 | + self.assertEqual(pool, 'first') |
| 30 | + self.assertTrue(self.sample_queue.get() == 'second') |
| 31 | + self.assertFalse(self.sample_queue.empty()) |
| 32 | + self.assertTrue(self.sample_queue.get() == 'first') |
| 33 | + self.assertTrue(self.sample_queue.empty()) |
0 commit comments