mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-08-24 10:45:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

revert cset 6a0da9b65e54 against sched.py committed by accident

Browse source
This commit is contained in:
Giampaolo Rodola' 2011-11-23 00:03:15 +01:00
parent 9329029ed7
commit c8cf4dfa2f
1 changed files with 0 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

8
Lib/sched.py
View file

@ -35,9 +35,6 @@ from collections import namedtuple
__all__ = ["scheduler"] __all__ = ["scheduler"]
class Event(namedtuple('Event', 'time, priority, action, argument, kwargs')): class Event(namedtuple('Event', 'time, priority, action, argument, kwargs')):
def __init__(self, *args, **kwargs):
super(Event, self).__init__(*args, **kwargs)
self._scheduled = False
def __eq__(s, o): return (s.time, s.priority) == (o.time, o.priority) def __eq__(s, o): return (s.time, s.priority) == (o.time, o.priority)
def __ne__(s, o): return (s.time, s.priority) != (o.time, o.priority) def __ne__(s, o): return (s.time, s.priority) != (o.time, o.priority)
def __lt__(s, o): return (s.time, s.priority) < (o.time, o.priority) def __lt__(s, o): return (s.time, s.priority) < (o.time, o.priority)
@ -62,7 +59,6 @@ class scheduler:
""" """
event = Event(time, priority, action, argument, kwargs) event = Event(time, priority, action, argument, kwargs)
event._scheduled = True
heapq.heappush(self._queue, event) heapq.heappush(self._queue, event)
return event # The ID return event # The ID
@ -85,9 +81,6 @@ class scheduler:
self._queue.remove(event) self._queue.remove(event)
heapq.heapify(self._queue) heapq.heapify(self._queue)
def is_scheduled(self, event):
return event._scheduled
def empty(self): def empty(self):
"""Check whether the queue is empty.""" """Check whether the queue is empty."""
return not self._queue return not self._queue
@ -129,7 +122,6 @@ class scheduler:
# Verify that the event was not removed or altered # Verify that the event was not removed or altered
# by another thread after we last looked at q[0]. # by another thread after we last looked at q[0].
if event is checked_event: if event is checked_event:
event._scheduled = False
action(*argument, **kwargs) action(*argument, **kwargs)
delayfunc(0) # Let other threads run delayfunc(0) # Let other threads run
else: else: