human/render/base_render.py

#encoding = utf8
import logging
import time
from abc import ABC, abstractmethod
from queue import Queue
from threading import Event, Thread

logger = logging.getLogger(__name__)


class BaseRender(ABC):
    def __init__(self, play_clock, delay=0.02):
        self._play_clock = play_clock
        self._delay = delay
        self._queue = Queue()
        self._exit_event = Event()
        self._thread = Thread(target=self._on_run)
        self._exit_event.set()
        self._thread.start()

    def _on_run(self):
        logging.info('Audio render run')
        while self._exit_event.is_set():
            self._run_step()
            time.sleep(self._delay)

        logging.info('Audio render exit')

    def put(self, frame):
        ps = time.time() - self._play_clock.start_time
        self._queue.put_nowait((frame, ps))

    def stop(self):
        self._queue.queue.clear()
        self._exit_event.clear()
        self._thread.join()

    @abstractmethod
    def _run_step(self):
        pass