diff options
| author | Zac Medico <zmedico@gentoo.org> | 2012-10-05 13:48:53 -0700 |
|---|---|---|
| committer | Zac Medico <zmedico@gentoo.org> | 2012-10-05 13:48:53 -0700 |
| commit | e4b64dd7dc7c2217055f110990b2496b71976681 (patch) | |
| tree | 9cfccd57286d0013556dc470cad9e3a54bde38ad /pym/_emerge/TaskScheduler.py | |
| parent | e58829dd5e2272b9c3878cd0ec92680fae075b40 (diff) | |
| download | portage-e4b64dd7dc7c2217055f110990b2496b71976681.tar.gz portage-e4b64dd7dc7c2217055f110990b2496b71976681.tar.bz2 portage-e4b64dd7dc7c2217055f110990b2496b71976681.zip | |
TaskScheduler: inherit AsyncScheduler
This allows the QueueScheduler class to be eliminated.
Diffstat (limited to 'pym/_emerge/TaskScheduler.py')
| -rw-r--r-- | pym/_emerge/TaskScheduler.py | 26 |
1 files changed, 0 insertions, 26 deletions
diff --git a/pym/_emerge/TaskScheduler.py b/pym/_emerge/TaskScheduler.py deleted file mode 100644 index 583bfe323..000000000 --- a/pym/_emerge/TaskScheduler.py +++ /dev/null @@ -1,26 +0,0 @@ -# Copyright 1999-2012 Gentoo Foundation -# Distributed under the terms of the GNU General Public License v2 - -from _emerge.QueueScheduler import QueueScheduler -from _emerge.SequentialTaskQueue import SequentialTaskQueue - -class TaskScheduler(object): - - """ - A simple way to handle scheduling of AsynchrousTask instances. Simply - add tasks and call run(). The run() method returns when no tasks remain. - """ - - def __init__(self, main=True, max_jobs=None, max_load=None): - self._queue = SequentialTaskQueue(max_jobs=max_jobs) - self._scheduler = QueueScheduler(main=main, - max_jobs=max_jobs, max_load=max_load) - self.sched_iface = self._scheduler.sched_iface - self.run = self._scheduler.run - self.clear = self._scheduler.clear - self.wait = self._queue.wait - self._scheduler.add(self._queue) - - def add(self, task): - self._queue.add(task) - |