Function _producer

modelscope/utils/file_utils.py:326–337

()

    read_error = [None]  # Mutable container for thread error propagation

    def _producer():
        try:
            with open(file_path, 'rb') as f:
                while True:
                    chunk = f.read(buffer_size)
                    if not chunk:
                        break
                    chunk_queue.put(chunk)
        except Exception as e:
            read_error[0] = e
        finally:
            chunk_queue.put(None)  # Sentinel to signal EOF

    reader_thread = threading.Thread(target=_producer, daemon=True)
    reader_thread.start()