This is an archive of the discontinued Mercurial Phabricator instance.

Status	Author	Revision
Closed	indygreg	D3963 merge: mark file gets as not thread safe
Closed	indygreg	D3962 worker: ability to disable thread unsafe tasks
Closed	indygreg	D3961 worker: rename variable to reflect constant

Diff 9629

	n = int(s)			n = int(s)
	if n >= 1:			if n >= 1:
	return n			return n
	except ValueError:			except ValueError:
	raise error.Abort(_('number of cpus must be an integer'))			raise error.Abort(_('number of cpus must be an integer'))
	return min(max(countcpus(), 4), 32)			return min(max(countcpus(), 4), 32)

	if pycompat.isposix or pycompat.iswindows:			if pycompat.isposix or pycompat.iswindows:
	_startupcost = 0.01			_STARTUP_COST = 0.01
	else:			else:
	_startupcost = 1e30			_STARTUP_COST = 1e30

	def worthwhile(ui, costperop, nops):			def worthwhile(ui, costperop, nops):
	'''try to determine whether the benefit of multiple processes can			'''try to determine whether the benefit of multiple processes can
	outweigh the cost of starting them'''			outweigh the cost of starting them'''
	linear = costperop * nops			linear = costperop * nops
	workers = _numworkers(ui)			workers = _numworkers(ui)
	benefit = linear - (_startupcost * workers + linear / workers)			benefit = linear - (_STARTUP_COST * workers + linear / workers)
	return benefit >= 0.15			return benefit >= 0.15

	def worker(ui, costperarg, func, staticargs, args):			def worker(ui, costperarg, func, staticargs, args):
	'''run a function, possibly in parallel in multiple worker			'''run a function, possibly in parallel in multiple worker
	processes.			processes.

	returns a progress iterator			returns a progress iterator