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
|
from locust import HttpUser, TaskSet, between, events, task
from gevent.lock import Semaphore
all_users_spawned = Semaphore()
all_users_spawned.acquire()
@events.init.add_listener
def _(environment, **kw):
@environment.events.spawning_complete.add_listener
def on_spawning_complete(**kw):
all_users_spawned.release()
class UserTasks(TaskSet):
def on_start(self):
all_users_spawned.wait()
self.wait()
@task
def index(self):
self.client.get("/")
class WebsiteUser(HttpUser):
host = "http://127.0.0.1:8089"
wait_time = between(2, 5)
tasks = [UserTasks]
|
