mirror of
https://github.com/python/cpython.git
synced 2025-11-20 10:57:44 +00:00
5b5e81c637
svn+ssh://pythondev@svn.python.org/python/trunk ........ r59606 | georg.brandl | 2007-12-29 11:57:00 +0100 (Sat, 29 Dec 2007) | 2 lines Some cleanup in the docs. ........ r59611 | martin.v.loewis | 2007-12-29 19:49:21 +0100 (Sat, 29 Dec 2007) | 2 lines Bug #1699: Define _BSD_SOURCE only on OpenBSD. ........ r59612 | raymond.hettinger | 2007-12-29 23:09:34 +0100 (Sat, 29 Dec 2007) | 1 line Simpler documentation for itertools.tee(). Should be backported. ........ r59613 | raymond.hettinger | 2007-12-29 23:16:24 +0100 (Sat, 29 Dec 2007) | 1 line Improve docs for itertools.groupby(). The use of xrange(0) to create a unique object is less obvious than object(). ........ r59620 | christian.heimes | 2007-12-31 15:47:07 +0100 (Mon, 31 Dec 2007) | 3 lines Added wininst-9.0.exe executable for VS 2008 Integrated bdist_wininst into PCBuild9 directory ........ r59621 | christian.heimes | 2007-12-31 15:51:18 +0100 (Mon, 31 Dec 2007) | 1 line Moved PCbuild directory to PC/VS7.1 ........ r59622 | christian.heimes | 2007-12-31 15:59:26 +0100 (Mon, 31 Dec 2007) | 1 line Fix paths for build bot ........ r59623 | christian.heimes | 2007-12-31 16:02:41 +0100 (Mon, 31 Dec 2007) | 1 line Fix paths for build bot, part 2 ........ r59624 | christian.heimes | 2007-12-31 16:18:55 +0100 (Mon, 31 Dec 2007) | 1 line Renamed PCBuild9 directory to PCBuild ........
100 lines
3.3 KiB
ReStructuredText
100 lines
3.3 KiB
ReStructuredText
:mod:`sched` --- Event scheduler
|
|
================================
|
|
|
|
.. module:: sched
|
|
:synopsis: General purpose event scheduler.
|
|
.. sectionauthor:: Moshe Zadka <moshez@zadka.site.co.il>
|
|
|
|
.. index:: single: event scheduling
|
|
|
|
The :mod:`sched` module defines a class which implements a general purpose event
|
|
scheduler:
|
|
|
|
|
|
.. class:: scheduler(timefunc, delayfunc)
|
|
|
|
The :class:`scheduler` class defines a generic interface to scheduling events.
|
|
It needs two functions to actually deal with the "outside world" --- *timefunc*
|
|
should be callable without arguments, and return a number (the "time", in any
|
|
units whatsoever). The *delayfunc* function should be callable with one
|
|
argument, compatible with the output of *timefunc*, and should delay that many
|
|
time units. *delayfunc* will also be called with the argument ``0`` after each
|
|
event is run to allow other threads an opportunity to run in multi-threaded
|
|
applications.
|
|
|
|
Example::
|
|
|
|
>>> import sched, time
|
|
>>> s=sched.scheduler(time.time, time.sleep)
|
|
>>> def print_time(): print("From print_time", time.time())
|
|
...
|
|
>>> def print_some_times():
|
|
... print(time.time())
|
|
... s.enter(5, 1, print_time, ())
|
|
... s.enter(10, 1, print_time, ())
|
|
... s.run()
|
|
... print(time.time())
|
|
...
|
|
>>> print_some_times()
|
|
930343690.257
|
|
From print_time 930343695.274
|
|
From print_time 930343700.273
|
|
930343700.276
|
|
|
|
|
|
.. _scheduler-objects:
|
|
|
|
Scheduler Objects
|
|
-----------------
|
|
|
|
:class:`scheduler` instances have the following methods:
|
|
|
|
|
|
.. method:: scheduler.enterabs(time, priority, action, argument)
|
|
|
|
Schedule a new event. The *time* argument should be a numeric type compatible
|
|
with the return value of the *timefunc* function passed to the constructor.
|
|
Events scheduled for the same *time* will be executed in the order of their
|
|
*priority*.
|
|
|
|
Executing the event means executing ``action(*argument)``. *argument* must be a
|
|
sequence holding the parameters for *action*.
|
|
|
|
Return value is an event which may be used for later cancellation of the event
|
|
(see :meth:`cancel`).
|
|
|
|
|
|
.. method:: scheduler.enter(delay, priority, action, argument)
|
|
|
|
Schedule an event for *delay* more time units. Other then the relative time, the
|
|
other arguments, the effect and the return value are the same as those for
|
|
:meth:`enterabs`.
|
|
|
|
|
|
.. method:: scheduler.cancel(event)
|
|
|
|
Remove the event from the queue. If *event* is not an event currently in the
|
|
queue, this method will raise a :exc:`RuntimeError`.
|
|
|
|
|
|
.. method:: scheduler.empty()
|
|
|
|
Return true if the event queue is empty.
|
|
|
|
|
|
.. method:: scheduler.run()
|
|
|
|
Run all scheduled events. This function will wait (using the :func:`delayfunc`
|
|
function passed to the constructor) for the next event, then execute it and so
|
|
on until there are no more scheduled events.
|
|
|
|
Either *action* or *delayfunc* can raise an exception. In either case, the
|
|
scheduler will maintain a consistent state and propagate the exception. If an
|
|
exception is raised by *action*, the event will not be attempted in future calls
|
|
to :meth:`run`.
|
|
|
|
If a sequence of events takes longer to run than the time available before the
|
|
next event, the scheduler will simply fall behind. No events will be dropped;
|
|
the calling code is responsible for canceling events which are no longer
|
|
pertinent.
|
|
|