code: def __init__(
      self,
      fname: str,
      schedule: Schedule,
      memory: np.ndarray,
      num_workers: int = 12,
  ):
      self.fname = fname
      self.schedule = schedule
      self.memory = memory
      self.queries = Queue()
      self.loaded_queue = Queue()
      self.num_workers = num_workers
      self.entered = False
      self.next_batch = 0
      self.loaded = set()
  
file_path: ffcv/ffcv/memory_managers/process_cache/schedule.py
imports: from collections import defaultdict
  from dataclasses import dataclass
  from typing import Mapping
  from queue import Queue
  import numpy
  from .page_reader import PageReader
label_desc: Use image node_id 1 to create a new ScheduleExecutor object  with example: obj = ScheduleExecutor(fname, schedule, memory, num_workers)