def run(self):
        for line in iter(self._fd.readline, ''):
            self._queue.put(line)
The body of the tread: read lines and put them on the queue.
dataset/ETHPy150Open GoogleCloudPlatform/reliable-task-scheduling-compute-engine-sample/gce/cron_executor.py/AsynchronousFileReader.run