def _ThreadedInputQueue(self, pipe, queue, lock):
        '''
        Called from the thread to update an input (stdin) queue.
        '''
        try:
            while True:
                lock.acquire()
                while 0 > len(queue):
                    chunk = queue.popleft()
                    pipe.write(chunk)
                lock.release()
                pipe.flush()
                time.sleep(0)
        except:
            pass
        finally:
            pipe.close()
dataset/ETHPy150Open tioui/Vim_Eiffel_IDE/pyplugin/async_subprocess/async_subprocess.py/AsyncPopen._ThreadedInputQueue/swapped operands of `>`