File: spawn.py

package info (click to toggle)
python-eventlet 0.26.1-7%2Bdeb11u1
  • links: PTS, VCS
  • area: main
  • in suites: bullseye
  • size: 2,916 kB
  • sloc: python: 24,898; makefile: 98
file content (79 lines) | stat: -rw-r--r-- 1,365 bytes parent folder | download | duplicates (4)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
import contextlib

import eventlet
import benchmarks


def dummy(i=None):
    return i


def linked(gt, arg):
    return arg


def benchmark_sleep():
    eventlet.sleep()


def benchmark_spawn_link1():
    t = eventlet.spawn(dummy)
    t.link(linked, 1)
    t.wait()


def benchmark_spawn_link5():
    t = eventlet.spawn(dummy)
    t.link(linked, 1)
    t.link(linked, 2)
    t.link(linked, 3)
    t.link(linked, 4)
    t.link(linked, 5)
    t.wait()


def benchmark_spawn_link5_unlink3():
    t = eventlet.spawn(dummy)
    t.link(linked, 1)
    t.link(linked, 2)
    t.link(linked, 3)
    t.link(linked, 4)
    t.link(linked, 5)
    t.unlink(linked, 3)
    t.wait()


@benchmarks.configure(max_iters=1e5)
def benchmark_spawn_nowait():
    eventlet.spawn(dummy, 1)


def benchmark_spawn():
    eventlet.spawn(dummy, 1).wait()


@benchmarks.configure(max_iters=1e5)
def benchmark_spawn_n():
    eventlet.spawn_n(dummy, 1)


@benchmarks.configure(max_iters=1e5)
def benchmark_spawn_n_kw():
    eventlet.spawn_n(dummy, i=1)


@contextlib.contextmanager
def pool_setup(iters):
    pool = eventlet.GreenPool(iters)
    yield pool
    pool.waitall()


@benchmarks.configure(manager=pool_setup)
def benchmark_pool_spawn(pool):
    pool.spawn(dummy, 1)


@benchmarks.configure(manager=pool_setup, max_iters=1e5)
def benchmark_pool_spawn_n(pool):
    pool.spawn_n(dummy, 1)