Lines Matching refs:interpreters
17 interpreters = import_helper.import_module('_xxsubinterpreters') variable
38 interpreters.run_string(interp, script, shared)
50 while not interpreters.is_running(interp):
60 interpreters.run_string(interp, dedent(f"""
93 main = interpreters.get_main()
95 if interpreters.get_current() != main:
100 interpreters.run_string(id, source, shared)
115 main = interpreters.get_main()
128 if not isinstance(id, interpreters.InterpreterID):
129 id = interpreters.InterpreterID(id)
134 id = interpreters.create()
145 except interpreters.ChannelClosedError:
232 except interpreters.ChannelClosedError:
245 interpreters.channel_send(cid, b'spam')
250 interpreters.channel_recv(cid)
251 except interpreters.ChannelEmptyError:
256 interpreters.channel_recv(cid)
264 interpreters.channel_close(cid, **kwargs)
272 interpreters.channel_close(cid, **kwargs)
279 for id in interpreters.list_all():
283 interpreters.destroy(id)
289 for cid in interpreters.channel_list_all():
291 interpreters.channel_destroy(cid)
292 except interpreters.ChannelNotFoundError:
321 interpreters.is_shareable(obj))
353 interpreters.is_shareable(obj))
360 self.cid = interpreters.channel_create()
363 interpreters.channel_destroy(self.cid)
369 interpreters.channel_send(self.cid, obj)
370 got = interpreters.channel_recv(self.cid)
380 interpreters.channel_send(self.cid, obj)
381 got = interpreters.channel_recv(self.cid)
413 interpreters.channel_send(self.cid, i)
422 main = interpreters.get_main()
423 ids = interpreters.list_all()
427 main = interpreters.get_main()
428 first = interpreters.create()
429 second = interpreters.create()
430 ids = interpreters.list_all()
434 main = interpreters.get_main()
435 first = interpreters.create()
436 second = interpreters.create()
437 interpreters.destroy(first)
438 ids = interpreters.list_all()
445 main = interpreters.get_main()
446 cur = interpreters.get_current()
448 self.assertIsInstance(cur, interpreters.InterpreterID)
451 main = interpreters.get_main()
452 interp = interpreters.create()
460 _, expected = interpreters.list_all()
468 [expected] = interpreters.list_all()
469 main = interpreters.get_main()
471 self.assertIsInstance(main, interpreters.InterpreterID)
474 [expected] = interpreters.list_all()
475 interp = interpreters.create()
489 main = interpreters.get_main()
490 self.assertTrue(interpreters.is_running(main))
494 interp = interpreters.create()
495 self.assertFalse(interpreters.is_running(interp))
498 self.assertTrue(interpreters.is_running(interp))
499 self.assertFalse(interpreters.is_running(interp))
502 interp = interpreters.create()
513 interp = interpreters.create()
514 interpreters.destroy(interp)
516 interpreters.is_running(interp)
520 interpreters.is_running(1_000_000)
524 interpreters.is_running(-1)
530 id = interpreters.InterpreterID(10, force=True)
539 id = interpreters.InterpreterID(Int(), force=True)
543 self.assertRaises(TypeError, interpreters.InterpreterID, object())
544 self.assertRaises(TypeError, interpreters.InterpreterID, 10.0)
545 self.assertRaises(TypeError, interpreters.InterpreterID, '10')
546 self.assertRaises(TypeError, interpreters.InterpreterID, b'10')
547 self.assertRaises(ValueError, interpreters.InterpreterID, -1)
548 self.assertRaises(OverflowError, interpreters.InterpreterID, 2**64)
551 id = interpreters.channel_create()
553 interpreters.InterpreterID(int(id) + 1) # unforced
556 id = interpreters.InterpreterID(10, force=True)
560 id = interpreters.InterpreterID(10, force=True)
564 id1 = interpreters.create()
565 id2 = interpreters.InterpreterID(int(id1))
566 id3 = interpreters.create()
589 id = interpreters.create()
590 self.assertIsInstance(id, interpreters.InterpreterID)
592 self.assertIn(id, interpreters.list_all())
598 id = interpreters.create()
599 interpreters.destroy(id)
609 id = interpreters.create()
617 self.assertIn(id, interpreters.list_all())
620 main, = interpreters.list_all()
621 id1 = interpreters.create()
630 self.assertEqual(set(interpreters.list_all()), {main, id1, id2})
633 main, = interpreters.list_all()
634 id1 = interpreters.create()
649 self.assertEqual(set(interpreters.list_all()), {main, id1, id2})
652 before = set(interpreters.list_all())
656 id = interpreters.create()
660 interpreters.destroy(id)
662 id = interpreters.create()
663 self.assertEqual(set(interpreters.list_all()), before | {id})
666 before = set(interpreters.list_all())
668 id1 = interpreters.create()
669 id2 = interpreters.create()
670 id3 = interpreters.create()
672 interpreters.destroy(id1)
673 interpreters.destroy(id3)
675 id = interpreters.create()
676 self.assertEqual(set(interpreters.list_all()), before | {id, id2})
682 id1 = interpreters.create()
683 id2 = interpreters.create()
684 id3 = interpreters.create()
685 self.assertIn(id2, interpreters.list_all())
686 interpreters.destroy(id2)
687 self.assertNotIn(id2, interpreters.list_all())
688 self.assertIn(id1, interpreters.list_all())
689 self.assertIn(id3, interpreters.list_all())
692 before = set(interpreters.list_all())
695 id = interpreters.create()
697 self.assertEqual(set(interpreters.list_all()), before | ids)
699 interpreters.destroy(id)
700 self.assertEqual(set(interpreters.list_all()), before)
703 main, = interpreters.list_all()
705 interpreters.destroy(main)
709 interpreters.destroy(main)
716 id = interpreters.create()
717 interpreters.destroy(id)
719 interpreters.destroy(id)
723 interpreters.destroy(1_000_000)
727 interpreters.destroy(-1)
730 main, = interpreters.list_all()
731 id = interpreters.create()
740 interpreters.run_string(id, script)
741 self.assertEqual(set(interpreters.list_all()), {main, id})
744 main, = interpreters.list_all()
745 id1 = interpreters.create()
746 id2 = interpreters.create()
751 interpreters.run_string(id1, script)
753 self.assertEqual(set(interpreters.list_all()), {main, id1})
756 id = interpreters.create()
758 interpreters.destroy(id)
765 main, = interpreters.list_all()
766 interp = interpreters.create()
768 self.assertTrue(interpreters.is_running(interp),
773 interpreters.destroy(interp)
774 self.assertTrue(interpreters.is_running(interp))
781 self.id = interpreters.create()
786 interpreters.run_string(self.id, script)
795 interpreters.run_string(self.id, script)
805 subinterp = interpreters.create(isolated=False)
816 interpreters.run_string(subinterp, script)
837 interpreters.run_string(self.id, script)
846 interpreters.run_string(self.id, 'print("spam")')
850 while id in interpreters.list_all():
853 interpreters.run_string(id, 'print("spam")')
857 interpreters.run_string(-1, 'print("spam")')
861 interpreters.run_string('spam', 'print("spam")')
865 interpreters.run_string(self.id, 10)
869 interpreters.run_string(self.id, b'print("spam")')
873 with self.assertRaises(interpreters.RunFailedError) as caught:
885 interpreters.run_string(self.id, 'print("spam"')
889 interpreters.run_string(self.id, 'raise Exception("spam")')
893 interpreters.run_string(self.id, 'raise SystemExit(42)')
897 interpreters.run_string(self.id, dedent("""
903 interpreters.run_string(self.id, dedent("""
927 interpreters.run_string(self.id, script, shared)
937 interpreters.run_string(self.id, dedent("""
948 interpreters.run_string(self.id, script, shared)
958 interpreters.run_string(self.id, script)
979 interpreters.run_string(self.id, script, shared)
987 interpreters.run_string(self.id, dedent(f"""
1001 interpreters.run_string(self.id, dedent(f"""
1030 interpreters.run_string(self.id, script)
1077 cid = interpreters._channel_id(10, force=True)
1083 cid = interpreters._channel_id(10, send=True, force=True)
1086 cid = interpreters._channel_id(10, send=True, recv=False, force=True)
1089 cid = interpreters._channel_id(10, recv=True, force=True)
1092 cid = interpreters._channel_id(10, recv=True, send=False, force=True)
1095 cid = interpreters._channel_id(10, send=True, recv=True, force=True)
1103 cid = interpreters._channel_id(Int(), force=True)
1107 self.assertRaises(TypeError, interpreters._channel_id, object())
1108 self.assertRaises(TypeError, interpreters._channel_id, 10.0)
1109 self.assertRaises(TypeError, interpreters._channel_id, '10')
1110 self.assertRaises(TypeError, interpreters._channel_id, b'10')
1111 self.assertRaises(ValueError, interpreters._channel_id, -1)
1112 self.assertRaises(OverflowError, interpreters._channel_id, 2**64)
1116 interpreters._channel_id(10, send=False, recv=False)
1119 cid = interpreters.channel_create()
1120 with self.assertRaises(interpreters.ChannelNotFoundError):
1121 interpreters._channel_id(int(cid) + 1) # unforced
1124 cid = interpreters._channel_id(10, force=True)
1128 cid = interpreters._channel_id(10, force=True)
1131 cid = interpreters._channel_id(10, send=True, force=True)
1134 cid = interpreters._channel_id(10, recv=True, force=True)
1137 cid = interpreters._channel_id(10, send=True, recv=True, force=True)
1141 cid1 = interpreters.channel_create()
1142 cid2 = interpreters._channel_id(int(cid1))
1143 cid3 = interpreters.channel_create()
1166 cid = interpreters.channel_create()
1167 self.assertIsInstance(cid, interpreters.ChannelID)
1170 before = interpreters.channel_list_all()
1171 id1 = interpreters.channel_create()
1172 id2 = interpreters.channel_create()
1173 id3 = interpreters.channel_create()
1174 after = interpreters.channel_list_all()
1181 id1 = interpreters.create()
1189 id2 = interpreters.create()
1202 cid = interpreters.channel_create()
1203 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1204 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1210 interp0 = interpreters.get_main()
1211 cid = interpreters.channel_create()
1212 interpreters.channel_send(cid, "send")
1214 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1215 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1219 interp1 = interpreters.create()
1225 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1226 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1232 interp0 = interpreters.get_main()
1233 interp1 = interpreters.create()
1234 interp2 = interpreters.create()
1235 interp3 = interpreters.create()
1236 cid = interpreters.channel_create()
1238 interpreters.channel_send(cid, "send")
1251 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1252 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1258 interp0 = interpreters.get_main()
1259 interp1 = interpreters.create()
1260 cid = interpreters.channel_create()
1261 interpreters.channel_send(cid, "send")
1267 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1268 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1272 interpreters.destroy(interp1)
1274 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1275 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1283 interp0 = interpreters.get_main()
1284 interp1 = interpreters.create()
1285 interp2 = interpreters.create()
1286 cid = interpreters.channel_create()
1287 interpreters.channel_send(cid, "data")
1292 interpreters.channel_send(cid, "data")
1298 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1299 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1304 interpreters.channel_release(cid, send=True)
1306 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1307 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1317 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1318 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1324 interp0 = interpreters.get_main()
1325 interp1 = interpreters.create()
1326 cid = interpreters.channel_create()
1328 interpreters.channel_send(cid, "send")
1331 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1332 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1337 interpreters.channel_close(cid, force=True)
1339 with self.assertRaises(interpreters.ChannelClosedError):
1340 interpreters.channel_list_interpreters(cid, send=True)
1341 with self.assertRaises(interpreters.ChannelClosedError):
1342 interpreters.channel_list_interpreters(cid, send=False)
1346 interp0 = interpreters.get_main()
1347 interp1 = interpreters.create()
1348 cid = interpreters.channel_create()
1350 interpreters.channel_send(cid, "send")
1353 send_interps = interpreters.channel_list_interpreters(cid, send=True)
1354 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1359 interpreters.channel_close(cid, send=True)
1361 with self.assertRaises(interpreters.ChannelClosedError):
1362 interpreters.channel_list_interpreters(cid, send=True)
1364 recv_interps = interpreters.channel_list_interpreters(cid, send=False)
1373 with self.assertRaises(interpreters.ChannelClosedError):
1374 interpreters.channel_list_interpreters(cid, send=True)
1375 with self.assertRaises(interpreters.ChannelClosedError):
1376 interpreters.channel_list_interpreters(cid, send=False)
1381 cid = interpreters.channel_create()
1383 interpreters.channel_send(cid, orig)
1384 obj = interpreters.channel_recv(cid)
1390 id1 = interpreters.create()
1402 cid = interpreters.channel_create()
1403 id1 = interpreters.create()
1408 obj = interpreters.channel_recv(cid)
1413 cid = interpreters.channel_create()
1418 obj = interpreters.channel_recv(cid)
1420 except interpreters.ChannelEmptyError:
1422 interpreters.channel_send(cid, obj)
1426 interpreters.channel_send(cid, b'spam')
1428 obj = interpreters.channel_recv(cid)
1433 cid = interpreters.channel_create()
1434 id1 = interpreters.create()
1454 interpreters.channel_send(cid, b'spam')
1456 obj = interpreters.channel_recv(cid)
1461 with self.assertRaises(interpreters.ChannelNotFoundError):
1462 interpreters.channel_send(10, b'spam')
1465 with self.assertRaises(interpreters.ChannelNotFoundError):
1466 interpreters.channel_recv(10)
1469 cid = interpreters.channel_create()
1470 with self.assertRaises(interpreters.ChannelEmptyError):
1471 interpreters.channel_recv(cid)
1475 cid = interpreters.channel_create()
1476 obj1 = interpreters.channel_recv(cid, default)
1477 interpreters.channel_send(cid, None)
1478 interpreters.channel_send(cid, 1)
1479 interpreters.channel_send(cid, b'spam')
1480 interpreters.channel_send(cid, b'eggs')
1481 obj2 = interpreters.channel_recv(cid, default)
1482 obj3 = interpreters.channel_recv(cid, default)
1483 obj4 = interpreters.channel_recv(cid)
1484 obj5 = interpreters.channel_recv(cid, default)
1485 obj6 = interpreters.channel_recv(cid, default)
1495 cid = interpreters.channel_create()
1496 interp = interpreters.create()
1504 obj = interpreters.channel_recv(cid)
1514 cid = interpreters.channel_create()
1515 cid = interpreters._channel_id(cid, _resolve=True)
1516 interp = interpreters.create()
1524 obj = interpreters.channel_recv(cid)
1532 cid = interpreters.channel_create()
1533 interpreters.channel_send(cid, b'spam')
1534 interpreters.channel_recv(cid)
1535 interpreters.channel_close(cid)
1537 with self.assertRaises(interpreters.ChannelClosedError):
1538 interpreters.channel_send(cid, b'eggs')
1539 with self.assertRaises(interpreters.ChannelClosedError):
1540 interpreters.channel_recv(cid)
1543 cid = interpreters.channel_create()
1544 id1 = interpreters.create()
1545 id2 = interpreters.create()
1546 interpreters.run_string(id1, dedent(f"""
1550 interpreters.run_string(id2, dedent(f"""
1554 interpreters.channel_close(cid)
1555 with self.assertRaises(interpreters.RunFailedError) as cm:
1556 interpreters.run_string(id1, dedent(f"""
1560 with self.assertRaises(interpreters.RunFailedError) as cm:
1561 interpreters.run_string(id2, dedent(f"""
1567 cid = interpreters.channel_create()
1568 interpreters.channel_send(cid, b'spam')
1569 interpreters.channel_recv(cid)
1570 interpreters.channel_close(cid)
1572 with self.assertRaises(interpreters.ChannelClosedError):
1573 interpreters.channel_close(cid)
1584 cid = interpreters.channel_create()
1585 interpreters.channel_send(cid, b'spam')
1586 interpreters.channel_recv(cid)
1587 interpreters.channel_close(cid, send=send, recv=recv)
1589 with self.assertRaises(interpreters.ChannelClosedError):
1590 interpreters.channel_send(cid, b'eggs')
1591 with self.assertRaises(interpreters.ChannelClosedError):
1592 interpreters.channel_recv(cid)
1595 cid = interpreters.channel_create()
1596 interpreters.channel_send(cid, b'spam')
1597 interpreters.channel_send(cid, b'ham')
1599 with self.assertRaises(interpreters.ChannelNotEmptyError):
1600 interpreters.channel_close(cid)
1601 interpreters.channel_recv(cid)
1602 interpreters.channel_send(cid, b'eggs')
1605 cid = interpreters.channel_create()
1606 interpreters.channel_send(cid, b'spam')
1607 interpreters.channel_send(cid, b'ham')
1609 with self.assertRaises(interpreters.ChannelNotEmptyError):
1610 interpreters.channel_close(cid, recv=True)
1611 interpreters.channel_recv(cid)
1612 interpreters.channel_send(cid, b'eggs')
1613 interpreters.channel_recv(cid)
1614 interpreters.channel_recv(cid)
1615 interpreters.channel_close(cid, recv=True)
1618 cid = interpreters.channel_create()
1619 interpreters.channel_send(cid, b'spam')
1620 interpreters.channel_send(cid, b'ham')
1621 interpreters.channel_close(cid, send=True)
1623 with self.assertRaises(interpreters.ChannelClosedError):
1624 interpreters.channel_send(cid, b'eggs')
1625 interpreters.channel_recv(cid)
1626 interpreters.channel_recv(cid)
1627 with self.assertRaises(interpreters.ChannelClosedError):
1628 interpreters.channel_recv(cid)
1631 cid = interpreters.channel_create()
1632 interpreters.channel_send(cid, b'spam')
1633 interpreters.channel_send(cid, b'ham')
1635 with self.assertRaises(interpreters.ChannelNotEmptyError):
1636 interpreters.channel_close(cid, recv=True, send=True)
1637 interpreters.channel_recv(cid)
1638 interpreters.channel_send(cid, b'eggs')
1639 interpreters.channel_recv(cid)
1640 interpreters.channel_recv(cid)
1641 interpreters.channel_close(cid, recv=True)
1644 cid = interpreters.channel_create()
1645 interpreters.channel_send(cid, b'spam')
1646 interpreters.channel_send(cid, b'ham')
1647 interpreters.channel_close(cid, recv=True, force=True)
1649 with self.assertRaises(interpreters.ChannelClosedError):
1650 interpreters.channel_send(cid, b'eggs')
1651 with self.assertRaises(interpreters.ChannelClosedError):
1652 interpreters.channel_recv(cid)
1655 cid = interpreters.channel_create()
1656 interpreters.channel_send(cid, b'spam')
1657 interpreters.channel_send(cid, b'ham')
1658 interpreters.channel_close(cid, send=True, force=True)
1660 with self.assertRaises(interpreters.ChannelClosedError):
1661 interpreters.channel_send(cid, b'eggs')
1662 with self.assertRaises(interpreters.ChannelClosedError):
1663 interpreters.channel_recv(cid)
1666 cid = interpreters.channel_create()
1667 interpreters.channel_send(cid, b'spam')
1668 interpreters.channel_send(cid, b'ham')
1669 interpreters.channel_close(cid, send=True, recv=True, force=True)
1671 with self.assertRaises(interpreters.ChannelClosedError):
1672 interpreters.channel_send(cid, b'eggs')
1673 with self.assertRaises(interpreters.ChannelClosedError):
1674 interpreters.channel_recv(cid)
1677 cid = interpreters.channel_create()
1678 interpreters.channel_close(cid)
1680 with self.assertRaises(interpreters.ChannelClosedError):
1681 interpreters.channel_send(cid, b'spam')
1682 with self.assertRaises(interpreters.ChannelClosedError):
1683 interpreters.channel_recv(cid)
1686 cid = interpreters.channel_create()
1687 interpreters.channel_send(cid, b'spam')
1688 interp = interpreters.create()
1689 interpreters.run_string(interp, dedent(f"""
1693 with self.assertRaises(interpreters.ChannelClosedError):
1694 interpreters.channel_recv(cid)
1695 with self.assertRaises(interpreters.ChannelClosedError):
1696 interpreters.channel_close(cid)
1699 cid = interpreters.channel_create()
1700 interpreters.channel_send(cid, b'spam')
1701 interpreters.channel_send(cid, b'spam')
1702 interpreters.channel_send(cid, b'spam')
1703 interpreters.channel_recv(cid)
1704 interpreters.channel_close(cid, force=True)
1706 with self.assertRaises(interpreters.ChannelClosedError):
1707 interpreters.channel_send(cid, b'eggs')
1708 with self.assertRaises(interpreters.ChannelClosedError):
1709 interpreters.channel_recv(cid)
1712 cid = interpreters.channel_create()
1714 with self.assertRaises(interpreters.ChannelNotFoundError):
1715 interpreters.channel_list_interpreters(1000, send=True)
1717 interpreters.channel_close(cid)
1719 with self.assertRaises(interpreters.ChannelClosedError):
1720 interpreters.channel_list_interpreters(cid, send=True)
1724 cid = interpreters.channel_create()
1726 interpreters.channel_list_interpreters(cid)
1773 cid = interpreters.channel_create()
1774 interpreters.channel_send(cid, b'spam')
1775 interpreters.channel_recv(cid)
1776 interpreters.channel_release(cid, send=True, recv=True)
1778 with self.assertRaises(interpreters.ChannelClosedError):
1779 interpreters.channel_send(cid, b'eggs')
1780 with self.assertRaises(interpreters.ChannelClosedError):
1781 interpreters.channel_recv(cid)
1784 cid = interpreters.channel_create()
1785 id1 = interpreters.create()
1786 id2 = interpreters.create()
1787 interpreters.run_string(id1, dedent(f"""
1797 interpreters.run_string(id1, dedent(f"""
1804 cid = interpreters.channel_create()
1805 interpreters.channel_send(cid, b'spam')
1806 interpreters.channel_recv(cid)
1807 interpreters.channel_release(cid)
1809 with self.assertRaises(interpreters.ChannelClosedError):
1810 interpreters.channel_send(cid, b'eggs')
1811 with self.assertRaises(interpreters.ChannelClosedError):
1812 interpreters.channel_recv(cid)
1815 cid = interpreters.channel_create()
1816 interpreters.channel_send(cid, b'spam')
1817 interpreters.channel_recv(cid)
1818 interpreters.channel_release(cid, send=True, recv=True)
1820 with self.assertRaises(interpreters.ChannelClosedError):
1821 interpreters.channel_release(cid, send=True, recv=True)
1824 cid = interpreters.channel_create()
1825 interpreters.channel_send(cid, b'spam')
1826 interpreters.channel_send(cid, b'ham')
1827 interpreters.channel_release(cid, send=True, recv=True)
1829 with self.assertRaises(interpreters.ChannelClosedError):
1830 interpreters.channel_recv(cid)
1833 cid = interpreters.channel_create()
1834 interpreters.channel_release(cid)
1836 with self.assertRaises(interpreters.ChannelClosedError):
1837 interpreters.channel_send(cid, b'spam')
1838 with self.assertRaises(interpreters.ChannelClosedError):
1839 interpreters.channel_recv(cid)
1842 cid = interpreters.channel_create()
1843 interpreters.channel_send(cid, b'spam')
1844 interp = interpreters.create()
1845 interpreters.run_string(interp, dedent(f"""
1849 obj = interpreters.channel_recv(cid)
1850 interpreters.channel_release(cid)
1852 with self.assertRaises(interpreters.ChannelClosedError):
1853 interpreters.channel_send(cid, b'eggs')
1858 cid = interpreters.channel_create()
1859 interp = interpreters.create()
1860 interpreters.run_string(interp, dedent(f"""
1866 with self.assertRaises(interpreters.ChannelClosedError):
1867 interpreters.channel_recv(cid)
1871 cid = interpreters.channel_create()
1872 interpreters.channel_send(cid, None)
1873 interpreters.channel_recv(cid)
1874 interpreters.channel_send(cid, b'spam')
1875 interpreters.channel_release(cid, send=True)
1876 obj = interpreters.channel_recv(cid)
1881 cid = interpreters.channel_create()
1882 interpreters.channel_send(cid, b'spam')
1883 interpreters.channel_send(cid, b'spam')
1884 interpreters.channel_send(cid, b'spam')
1885 interpreters.channel_recv(cid)
1886 interpreters.channel_release(cid, send=True, recv=True)
1888 with self.assertRaises(interpreters.ChannelClosedError):
1889 interpreters.channel_send(cid, b'eggs')
1890 with self.assertRaises(interpreters.ChannelClosedError):
1891 interpreters.channel_recv(cid)
1961 return interpreters.channel_create()
1963 ch = interpreters.channel_create()
1972 self._cid = interpreters.channel_recv(ch)
2190 _cid = interpreters.channel_create()
2203 pending=int.from_bytes(interpreters.channel_recv(_cid), 'little'),
2204 closed=bool(interpreters.channel_recv(_cid)),
2210 interpreters = [
2216 for interp, other, extra in interpreters:
2227 with self.assertRaises(interpreters.ChannelClosedError):
2232 with self.assertRaises(interpreters.ChannelClosedError):
2233 interpreters.channel_recv(fix.cid)
2234 with self.assertRaises(interpreters.ChannelClosedError):
2235 interpreters.channel_send(fix.cid, b'spam')
2236 with self.assertRaises(interpreters.ChannelClosedError):
2237 interpreters.channel_close(fix.cid)
2238 with self.assertRaises(interpreters.ChannelClosedError):
2239 interpreters.channel_close(fix.cid, force=True)
2262 interpreters.channel_recv(fix.cid)