(self)
| 912 | return results |
| 913 | |
| 914 | def test_basic(self): |
| 915 | # Basic tests for get(), put() etc. |
| 916 | q = self.q |
| 917 | self.assertTrue(q.empty()) |
| 918 | self.assertEqual(q.qsize(), 0) |
| 919 | q.put(1) |
| 920 | self.assertFalse(q.empty()) |
| 921 | self.assertEqual(q.qsize(), 1) |
| 922 | q.put(2) |
| 923 | q.put_nowait(3) |
| 924 | q.put(4) |
| 925 | self.assertFalse(q.empty()) |
| 926 | self.assertEqual(q.qsize(), 4) |
| 927 | |
| 928 | self.assertEqual(q.get(), 1) |
| 929 | self.assertEqual(q.qsize(), 3) |
| 930 | |
| 931 | self.assertEqual(q.get_nowait(), 2) |
| 932 | self.assertEqual(q.qsize(), 2) |
| 933 | |
| 934 | self.assertEqual(q.get(block=False), 3) |
| 935 | self.assertFalse(q.empty()) |
| 936 | self.assertEqual(q.qsize(), 1) |
| 937 | |
| 938 | self.assertEqual(q.get(timeout=0.1), 4) |
| 939 | self.assertTrue(q.empty()) |
| 940 | self.assertEqual(q.qsize(), 0) |
| 941 | |
| 942 | with self.assertRaises(self.queue.Empty): |
| 943 | q.get(block=False) |
| 944 | with self.assertRaises(self.queue.Empty): |
| 945 | q.get(timeout=1e-3) |
| 946 | with self.assertRaises(self.queue.Empty): |
| 947 | q.get_nowait() |
| 948 | self.assertTrue(q.empty()) |
| 949 | self.assertEqual(q.qsize(), 0) |
| 950 | |
| 951 | def test_negative_timeout_raises_exception(self): |
| 952 | q = self.q |
nothing calls this directly
no test coverage detected