123456789101112131415161718192021222324252627282930313233343536373839404142 |
- import os
- import ujson
- from socketify import App
- def plaintext(res, req):
- res.send(b'Hello, World!')
- def applicationjson(res, req):
- res.send({"message":"Hello, World!"})
- def run_app():
- app = App(None, 200_000, 0)
- app.json_serializer(ujson)
- app.get("/", plaintext)
- app.get("/json", applicationjson)
- app.get("/plaintext", plaintext)
- app.listen(3000)
- app.run()
-
- def create_fork():
- n = os.fork()
- # n greater than 0 means parent process
- if not n > 0:
- run_app()
- def get_worker_count():
- try:
- return int(os.environ["WORKER_COUNT"])
- except:
- return 2
- WORKER_COUNT = get_worker_count() - 1
- for index in range(WORKER_COUNT):
- create_fork()
- run_app()
|