threadlet 3.0.0

Threads with results

threadlet

• Task is an object for containing a function and a Future object to store a result of the function.
• Worker is a thread with a loop over incoming tasks.
• SimpleThreadPoolExecutor is a more efficient variant of the concurrent.futures.ThreadPoolExecutor which spawns all the threads at the beginning.

---

Table of Contents

• Installation
• License
• Usage

Installation

pip install threadlet

License

threadlet is distributed under the terms of the MIT license.

Usage

from threadlet import Task, Worker, SimpleThreadPoolExecutor


def calc(x):
    return x * 2


# run task asynchronously in a separate thread
future = Task(calc, 2).start()
assert future.result() == 4

# spawns one thread to sequentially handle all submitted functions
with Worker() as w:
    f1 = w.submit(calc, 3)
    f2 = w.submit(calc, 4)
    assert f1.result() == 6
    assert f2.result() == 8

# spawns 4 threads to handle all tasks in parallel
with SimpleThreadPoolExecutor(4) as tpe:
    future = tpe.submit(calc, 5)
    assert future.result() == 10