comparison mercurial/worker.py @ 46240:a42502e9ae6d

worker: POSIX only supports workers from main thread (issue6460)

The POSIX backend sets signal handlers for SIGINT (maybe avoidable) and
SIGCHLD (necessary for waitpid). Python up to 3.9 only allow this from
the main thread, so disable the worker feature otherwise.

Differential Revision: https://phab.mercurial-scm.org/D9660

46239:d159d0fafa78

    return min(max(countcpus(), 4), 32)


if pycompat.ispy3:

    class _blockingreader(object):
        def __init__(self, wrapped):
            self._wrapped = wrapped

        # Do NOT implement readinto() by making it delegate to

            del buf[pos:]
            return bytes(buf)


else:

    def _blockingreader(wrapped):
        return wrapped

    threadsafe - whether work items are thread safe and can be executed using
    a thread-based worker. Should be disabled for CPU heavy tasks that don't
    release the GIL.
    """
    enabled = ui.configbool(b'worker', b'enabled')
    if enabled and worthwhile(ui, costperarg, len(args), threadsafe=threadsafe):
        return _platformworker(ui, func, staticargs, args, hasretval)
    return func(*staticargs + (args,))

46240:a42502e9ae6d

    return min(max(countcpus(), 4), 32)


if pycompat.ispy3:

    def ismainthread():
        return threading.current_thread() == threading.main_thread()

    class _blockingreader(object):
        def __init__(self, wrapped):
            self._wrapped = wrapped

        # Do NOT implement readinto() by making it delegate to

            del buf[pos:]
            return bytes(buf)


else:

    def ismainthread():
        return isinstance(threading.current_thread(), threading._MainThread)

    def _blockingreader(wrapped):
        return wrapped

    threadsafe - whether work items are thread safe and can be executed using
    a thread-based worker. Should be disabled for CPU heavy tasks that don't
    release the GIL.
    """
    enabled = ui.configbool(b'worker', b'enabled')
    if enabled and _platformworker is _posixworker and not ismainthread():
        # The POSIX worker has to install a handler for SIGCHLD.
        # Python up to 3.9 only allows this in the main thread.
        enabled = False

    if enabled and worthwhile(ui, costperarg, len(args), threadsafe=threadsafe):
        return _platformworker(ui, func, staticargs, args, hasretval)
    return func(*staticargs + (args,))