|
2 | 2 | import six
|
3 | 3 | if six.PY2:
|
4 | 4 | str = unicode
|
| 5 | + import Queue as queue |
| 6 | +else: |
| 7 | + import queue |
5 | 8 |
|
6 | 9 | # stdlib imports
|
7 | 10 |
|
@@ -1496,7 +1499,7 @@ def __init__(self, container, exp_config, to_singleshot, from_singleshot, to_mul
|
1496 | 1499 | # A queue for storing incoming files from the ZMQ server so
|
1497 | 1500 | # the server can keep receiving files even if analysis is slow
|
1498 | 1501 | # or paused:
|
1499 |
| - self.incoming_queue = Queue.Queue() |
| 1502 | + self.incoming_queue = queue.Queue() |
1500 | 1503 |
|
1501 | 1504 | # Start the thread to handle incoming files, and store them in
|
1502 | 1505 | # a buffer if processing is paused:
|
@@ -1601,7 +1604,7 @@ def incoming_buffer_loop(self):
|
1601 | 1604 | while True:
|
1602 | 1605 | try:
|
1603 | 1606 | filepath = self.incoming_queue.get(False)
|
1604 |
| - except Queue.Empty: |
| 1607 | + except queue.Empty: |
1605 | 1608 | break
|
1606 | 1609 | else:
|
1607 | 1610 | filepaths.append(filepath)
|
@@ -1755,12 +1758,12 @@ def __init__(self):
|
1755 | 1758 |
|
1756 | 1759 | # The singleshot routinebox will be connected to the filebox
|
1757 | 1760 | # by queues:
|
1758 |
| - to_singleshot = Queue.Queue() |
1759 |
| - from_singleshot = Queue.Queue() |
| 1761 | + to_singleshot = queue.Queue() |
| 1762 | + from_singleshot = queue.Queue() |
1760 | 1763 |
|
1761 | 1764 | # So will the multishot routinebox:
|
1762 |
| - to_multishot = Queue.Queue() |
1763 |
| - from_multishot = Queue.Queue() |
| 1765 | + to_multishot = queue.Queue() |
| 1766 | + from_multishot = queue.Queue() |
1764 | 1767 |
|
1765 | 1768 | self.output_box = OutputBox(self.ui.verticalLayout_output_box)
|
1766 | 1769 | self.singleshot_routinebox = RoutineBox(self.ui.verticalLayout_singleshot_routinebox, self.exp_config,
|
|
0 commit comments