X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=parallelize.py;h=77d7649fe956a1542c1a60ce99ca96365ef59ce0;hb=47ece7bceb442d70ddcc3c728533c4d4d2bccde4;hp=98f883c5716ae8fa3d67101b1d38d20dece7a0b6;hpb=36fea7f15ed17150691b5b3ead75450e575229ef;p=python_utils.git diff --git a/parallelize.py b/parallelize.py index 98f883c..77d7649 100644 --- a/parallelize.py +++ b/parallelize.py @@ -1,23 +1,26 @@ #!/usr/bin/env python3 +# © Copyright 2021-2022, Scott Gasch + """A decorator to help with dead simple parallelization.""" + import atexit -from enum import Enum import functools import typing +from enum import Enum class Method(Enum): + """How should we parallelize; by threads, processes or remote workers?""" + THREAD = 1 PROCESS = 2 REMOTE = 3 def parallelize( - _funct: typing.Optional[typing.Callable] = None, - *, - method: Method = Method.THREAD + _funct: typing.Optional[typing.Callable] = None, *, method: Method = Method.THREAD ) -> typing.Callable: """Usage: