From e4b64dd7dc7c2217055f110990b2496b71976681 Mon Sep 17 00:00:00 2001 From: Zac Medico Date: Fri, 5 Oct 2012 13:48:53 -0700 Subject: TaskScheduler: inherit AsyncScheduler This allows the QueueScheduler class to be eliminated. --- pym/_emerge/TaskScheduler.py | 26 -------------------------- 1 file changed, 26 deletions(-) delete mode 100644 pym/_emerge/TaskScheduler.py (limited to 'pym/_emerge/TaskScheduler.py') 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) - -- cgit v1.2.3-1-g7c22