Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(20)  |  Call(12)  |  Derive(0)  |  Import(8)

src/p/o/portage-funtoo-HEAD/pym/portage/_emirrordist/MirrorDistTask.py   portage-funtoo(Download)
import portage
from portage import os
from portage.util._async.TaskScheduler import TaskScheduler
from _emerge.CompositeTask import CompositeTask
from .FetchIterator import FetchIterator
	def _start(self):
		self._term_check_id = self.scheduler.idle_add(self._termination_check)
		fetch = TaskScheduler(iter(FetchIterator(self._config)),
			max_jobs=self._config.options.jobs,
			max_load=self._config.options.load_average,
 
		if self._config.options.delete:
			deletion = TaskScheduler(iter(DeletionIterator(self._config)),
				max_jobs=self._config.options.jobs,
				max_load=self._config.options.load_average,

src/p/o/portage-HEAD/pym/portage/_emirrordist/MirrorDistTask.py   portage(Download)
import portage
from portage import os
from portage.util._async.TaskScheduler import TaskScheduler
from _emerge.CompositeTask import CompositeTask
from .FetchIterator import FetchIterator
	def _start(self):
		self._term_check_id = self.scheduler.idle_add(self._termination_check)
		fetch = TaskScheduler(iter(FetchIterator(self._config)),
			max_jobs=self._config.options.jobs,
			max_load=self._config.options.load_average,
 
		if self._config.options.delete:
			deletion = TaskScheduler(iter(DeletionIterator(self._config)),
				max_jobs=self._config.options.jobs,
				max_load=self._config.options.load_average,

src/p/o/portage-funtoo-HEAD/pym/_emerge/depgraph.py   portage-funtoo(Download)
from portage.util import writemsg_level, write_atomic
from portage.util.digraph import digraph
from portage.util._async.TaskScheduler import TaskScheduler
from portage.util._eventloop.EventLoop import EventLoop
from portage.util._eventloop.global_event_loop import global_event_loop
					max_load = self._frozen_config.myopts.get("--load-average")
					scheduler = TaskScheduler(
						self._dynamic_deps_preload(fake_vartree, fakedb),
						max_jobs=max_jobs,
						max_load=max_load,

src/p/o/portage-HEAD/pym/_emerge/depgraph.py   portage(Download)
from portage.util import writemsg_level, write_atomic
from portage.util.digraph import digraph
from portage.util._async.TaskScheduler import TaskScheduler
from portage.util._eventloop.EventLoop import EventLoop
from portage.util._eventloop.global_event_loop import global_event_loop
					max_load = self._frozen_config.myopts.get("--load-average")
					scheduler = TaskScheduler(
						self._dynamic_deps_preload(fake_vartree),
						max_jobs=max_jobs,
						max_load=max_load,

src/p/o/portage-funtoo-HEAD/pym/portage/tests/ebuild/test_ipc_daemon.py   portage-funtoo(Download)
from portage.util import ensure_dirs
from portage.util._async.ForkProcess import ForkProcess
from portage.util._async.TaskScheduler import TaskScheduler
from portage.util._eventloop.global_event_loop import global_event_loop
from _emerge.SpawnProcess import SpawnProcess
					'"$PORTAGE_BIN_PATH"/ebuild-ipc exit %d' % exitcode],
					env=env)
				task_scheduler = TaskScheduler(iter([daemon, proc]),
					max_jobs=2, event_loop=event_loop)
 
					output_fifo=output_fifo)
				proc = SleepProcess(seconds=sleep_time_s)
				task_scheduler = TaskScheduler(iter([daemon, proc]),
					max_jobs=2, event_loop=event_loop)
 

src/p/o/portage-HEAD/pym/portage/tests/ebuild/test_ipc_daemon.py   portage(Download)
from portage.util import ensure_dirs
from portage.util._async.ForkProcess import ForkProcess
from portage.util._async.TaskScheduler import TaskScheduler
from portage.util._eventloop.global_event_loop import global_event_loop
from _emerge.SpawnProcess import SpawnProcess
					'"$PORTAGE_BIN_PATH"/ebuild-ipc exit %d' % exitcode],
					env=env)
				task_scheduler = TaskScheduler(iter([daemon, proc]),
					max_jobs=2, event_loop=event_loop)
 
					output_fifo=output_fifo)
				proc = SleepProcess(seconds=sleep_time_s)
				task_scheduler = TaskScheduler(iter([daemon, proc]),
					max_jobs=2, event_loop=event_loop)
 

src/p/o/portage-funtoo-HEAD/pym/portage/tests/process/test_poll.py   portage-funtoo(Download)
from portage.tests import TestCase
from portage.util._pty import _create_pty_or_pipe
from portage.util._async.TaskScheduler import TaskScheduler
from _emerge.PipeReader import PipeReader
from _emerge.SpawnProcess import SpawnProcess
			_use_array=self._use_array)
 
		task_scheduler = TaskScheduler(iter([producer, consumer]), max_jobs=2)
 
		# This will ensure that both tasks have exited, which

src/p/o/portage-HEAD/pym/portage/tests/ebuild/test_doebuild_fd_pipes.py   portage(Download)
from portage.package.ebuild._ipc.QueryCommand import QueryCommand
from portage.util._async.ForkProcess import ForkProcess
from portage.util._async.TaskScheduler import TaskScheduler
from portage.util._eventloop.global_event_loop import global_event_loop
from _emerge.Package import Package
					input_files={"producer" : pr})
 
				task_scheduler = TaskScheduler(iter([producer, consumer]),
					max_jobs=2)