add sharing state between processes example (#390)

* clean up

* add sharing state between process example

* clean up

Author: nggit

deployment/example_app/entrypoint.sh

@@ -1,11 +1,10 @@
 
-UID="$(id -u app 2>/dev/null)"
+USER=app
+UID="$(id -u "$USER" 2>/dev/null)"
 
 if [ -z "$UID" ]; then
     UID=0
     USER=root
-else
-    USER=app
 fi
 
 if [ "$UID" -lt 10000 ]; then

examples/multiprocess_dict.py

@@ -0,0 +1,32 @@
+#!/usr/bin/env python3
+# SPDX-License-Identifier: MIT
+# Author: Anggit Arfanto
+# Description: Sharing state between processes.
+
+import multiprocessing as mp
+
+from tremolo import Application
+
+app = Application()
+
+
+@app.route('/')
+def hello(request, response, **server):
+    g = server['globals']
+    mystate = g.options['mystate']
+    process = mp.current_process()
+
+    if process.name not in mystate:
+        mystate[process.name] = None
+        return f'Detected {process.name}'
+
+    return f'Hello from: {process.name}. Workers detected: {len(mystate)}'
+
+
+if __name__ == '__main__':
+    with mp.Manager() as manager:
+        mystate = manager.dict()
+
+        # `app.run()` accepts extra/arbitrary options
+        app.run('0.0.0.0', 8000, debug=True, worker_num=4, keepalive_timeout=1,
+                mystate=mystate)

hello.py

@@ -7,7 +7,7 @@
 
 @app.route('/hello')
 async def hello_world(**server):
-    return 'Hello world!', 'latin-1'
+    return 'Hello World!', 'latin-1'
 
 
 if __name__ == '__main__':

tremolo/tremolo.py

@@ -565,7 +565,6 @@ def create_sock(self, host, port, reuse_port=True):
             sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 
         sock.setblocking(False)
-        sock.set_inheritable(True)
 
         if sock.family.name == 'AF_UNIX':
             if not host.endswith('.sock'):