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