模拟一定数量的用户，同时并发请求。

    1. from gevent._semaphore import BoundedSemaphore
    3. # 创建集合点
    4. all_locusts_spawned = BoundedSemaphore()
    5. all_locusts_spawned.acquire()
    8. # 注册事件
    9. @events.spawning_complete.add_listener
    10. def on_hatch_complete(**kwargs):
    11.     all_locusts_spawned.release()  
    14. class ApiUser(TaskSet):
    15.     """压测op操作"""
    16.     index = 1
    18.     @task(15)
    19.     def test_op(self):
    20.         """op操作"""
    21.         all_locusts_spawned.wait()  # 限制在所有用户准备完成前处于等待状态
    22.         self.client.send('42["operation",{'
    23.                          f'"revision":{self.user.version_id.get(self.index)}'
    24.                          ',"op":[[["extra","user_state","275127340","current_stage_actor",{"r":true,"i":'
    25.                          f'"{uuid.uuid1()}"'
    26.                          '}]]]}]')
    27.         self.index += 1