^ jddlmZddlZddlZddlmZmZddlZddlm Z erddl m Z e dZ Gddej ZdS) ) annotationsN) TYPE_CHECKINGSet) debug_print)AbstractAudioPlayer debug_mediacPeZdZdZdZd fd Zd dZd dZd dZdd Z dd Z xZ S)PlayerWorkerThreadaWWorker thread for refilling audio players. This thread manages calling the ``work`` method on low level AudioPlayer instances (not the high level Player instances). This allows the players to keep their buffers filled (and perform event dispatching tasks), but does not block the main thread. This thread will sleep for a small period between updates, but provides a :py:meth:`~notify` method to allow waking it immediately. A :py:meth:`~stop` method is provided to terminate the thread, but under normal operation it will exit cleanly on interpreter shutdown. g{Gz?returnNonectdtj|_tj|_d|_t|_ dS)NT)daemonF) super__init__ threadingEvent _rest_eventLock_operation_lock_stoppedsetplayers)self __class__s \/home/agentuser/manim-venv/lib/python3.11/site-packages/pyglet/media/player_worker_thread.pyrzPlayerWorkerThread.__init__%sT %%%$?,,(~// 14 c tjdrtjd} td|dnd|sJ|j||jtdtjsJ|jrnO|j 5|j r&|j }|j D]}| nd}dddn #1swxYwYtdsJdS)N debug_traceTz'PlayerWorkerThread.run: Going to sleep zindefinitely; no active playerszfor z!PlayerWorkerThread.run: woke up @zPlayerWorkerThread.run: exiting) pygletoptions_install_trace_debugrwaitcleartimerrr _nap_timework)r sleep_timeplayers rrunzPlayerWorkerThread.run.s >- ( $  ! # # #  &pBLBT>>ZmakZmZmppqq q qq   ! !* - - -   " " $ $ $KdikkKKLL L LL} % & &<&!%J"&,&& &"&J & & & & & & & & & & & & & & & &&89999999s+0C''C+.C+ctdsJd|_|j |dS#t $rYdSwxYw)a&Stop the thread and wait for it to terminate. The ``stop`` instance variable is set to ``True`` and the rest event is set. It is the responsibility of the ``run`` method to check the value of ``_stopped`` after each sleep or wait and to return if set. zPlayerWorkerThread.stop()TN)r"rrrjoin RuntimeErrorrs rstopzPlayerWorkerThread.stopIsm122222    IIKKKKK    DD sA AAcZtdsJ|jdS)a"Interrupt the current sleep operation. If the thread is currently sleeping, it will be woken immediately instead of waiting the full duration of the timeout. If the thread is not sleeping, it will run again as soon as it is done with its operation. zPlayerWorkerThread.notify()N)r"rrr.s rnotifyzPlayerWorkerThread.notifyZs4344444 rr)rc|JtdsJ|j5|j|dddn #1swxYwY|dS)zAdd a player to the PlayerWorkerThread, and call :py:meth:`~notify`. When a player is added, it's ``work`` method will be called regularly. .. note:: Do not call this method from within the thread, as it will deadlock. Nz PlayerWorkerThread: player added)r"rraddr1rr)s rr3zPlayerWorkerThread.addes!!!899999  ! % % L  V $ $ $ % % % % % % % % % % % % % % % sAA ActdsJ||jvr<|j5|j|ddddS#1swxYwYdSdS)zRemove a player from the PlayerWorkerThread. This call has no effect if the player does not exist. .. note:: Do not call this method from within the thread, as it will deadlock. z"PlayerWorkerThread: player removedN)r"rrremover4s rr6zPlayerWorkerThread.removets:;;;;; T\ ! !% , , ##F+++ , , , , , , , , , , , , , , , , , , " !sA  AA)r r )r)rr r ) __name__ __module__ __qualname____doc__r&rr*r/r1r3r6 __classcell__)rs@rr r s  I777777::::6"         , , , , , , , ,rr ) __future__rr%rtypingrrr pyglet.utilrpyglet.media.drivers.baserr"Threadr rrrBs"""""" %%%%%%%% ######>====== ] # #l,l,l,l,l,)l,l,l,l,l,r