🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 14:19:05 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
scheduler
/
mainloop
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/mainloop/__pycache__
🔄 Refresh
✏️
Editing: pygamescheduler.cpython-38.pyc
Read Only
U v�i� � @ s� d dl Z d dlZd dlmZmZmZ d dlmZmZ d dlm Z d dl m Z ddl m Z ddlmZ ed �Ze �d �ZG d d � d e �ZdS ) � N)�Any�Optional�TypeVar)�abc�typing)� PriorityQueue)� DELTA_ZERO� )�PeriodicScheduler)� ScheduledItem�_TStateZRxc s� e Zd ZdZed�� fdd� Zdeje e e e j d�dd�Z dej eje e e e j d �d d �Zdejeje e e e j d �d d �Zdd�dd�Z� ZS )�PyGameSchedulerz�A scheduler that schedules works for PyGame. Note that this class expects the caller to invoke run() repeatedly. http://www.pygame.org/docs/ref/time.html http://www.pygame.org/docs/ref/event.html)�pygamec s& t � �� || _t�� | _t� | _dS )z�Create a new PyGameScheduler. Args: pygame: The PyGame module to use; typically, you would get this by import pygame N)�super�__init__Z_pygame� threading�Lock�_lockr �_queue)�selfr �� __class__� �]/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/mainloop/pygamescheduler.pyr s zPyGameScheduler.__init__N)�action�state�returnc C s t �d|� | j| j||d�S )a! Schedules an action to be executed. Args: action: Action to be executed. state: [Optional] state to be given to the action function. Returns: The disposable object used to cancel the scheduled action (best effort). z"PyGameScheduler.schedule(state=%s)�r )�log�debug�schedule_absolute�now)r r r r r r �schedule& s zPyGameScheduler.schedule)�duetimer r r c C s& t t| �|��}| j| j| ||d�S )at Schedules an action to be executed after duetime. Args: duetime: Relative time after which to execute the action. action: Action to be executed. state: [Optional] state to be given to the action function. Returns: The disposable object used to cancel the scheduled action (best effort). r )�maxr Z to_timedeltar r! )r r# r r r r r �schedule_relative7 s z!PyGameScheduler.schedule_relativec C s< | � |�}t| |||�}| j� | j�|� W 5 Q R X |jS )ao Schedules an action to be executed at duetime. Args: duetime: Absolute time at which to execute the action. action: Action to be executed. state: [Optional] state to be given to the action function. Returns: The disposable object used to cancel the scheduled action (best effort). )� to_datetimer r r �enqueueZ disposable)r r# r r �sir r r r K s z!PyGameScheduler.schedule_absolute)r c C sb | j r^| j�: | j �� }|j| j }|tkr8W 5 Q R � q^| j �� }W 5 Q R X |�� s |�� q d S )N) r r �peekr# r! r �dequeueZ is_cancelledZinvoke)r �item�diffr r r �rune s zPyGameScheduler.run)N)N)N)�__name__� __module__� __qualname__�__doc__r r r ZScheduledActionr r r ZDisposableBaser" Z RelativeTimer% Z AbsoluteTimer r- � __classcell__r r r r r s. � � �� �� r )�loggingr r r r r Z reactivexr Zreactivex.internalr Z reactivex.internal.constantsr Zperiodicschedulerr Z scheduleditemr r � getLoggerr r r r r r �<module> s
💾 Save Changes
❌ Cancel