多线程

draw/README

@@ -0,0 +1,6 @@
+/usr/local/python3/bin/uwsgi --ini uwsgi.ini             # 启动
+/usr/local/python3/bin/uwsgi --reload uwsgi.ini          # 重启
+/usr/local/python3/bin/uwsgi --stop uwsgi.ini            # 关闭
+
+使用 gevent
+uwsgi --gevent 100 --gevent-monkey-patch --ini uwsgi.ini

draw/multi_thread.py

@@ -0,0 +1,18 @@
+import multiprocessing
+
+import tensorflow as tf
+
+def f(x):
+    session = tf.Session()
+    a = tf.Variable(x, name='a')
+    b = tf.Variable(100, name='b')
+    c = tf.multiply(a, b, name='c')
+    session.run(tf.global_variables_initializer())
+
+    out = session.run(c)
+    print("OK: %s" % out)
+
+if __name__ == '__main__':
+    multiprocessing.set_start_method('spawn')  # Comment me out to hang
+    f(0)
+    multiprocessing.Pool().map(f, range(10))

draw/requirement.txt

@@ -2,4 +2,6 @@ opencv-python-headless
 tensorflow
 opencv-python
 mtcnn
-traceback2
+traceback2
+uwsgi
+gevent

draw/uwsgi.ini

@@ -0,0 +1,12 @@
+[uwsgi]
+http = 0.0.0.0:5000
+chdir =/home/code/quantization-spider/bbztx/
+wsgi-file = /home/code/quantization-spider/bbztx/s1.py
+processes = 1
+threads = 8
+buffer-size = 32768
+master = false
+pidfile = uwsgi.pid
+daemonize = uwsgi.log
+callable = app
+cheaper = 0

draw/web_index.py

@@ -33,6 +33,8 @@ _logger = logger(__name__)
 
 @app.route('/')
 def hello_world():
+    time.sleep(1)
+    print(int(round(time.time() * 1000)))
     return 'Hello World!'
 
 import requests
@@ -80,9 +82,9 @@ from gevent import pywsgi
 import traceback
 if __name__ == '__main__':
     try:
-        # app.run(host='192.168.0.220', port=5000)
-        server = pywsgi.WSGIServer(('0.0.0.0', 5000), app)
-        server.serve_forever()
+        app.run(host='192.168.0.220', port=5000)
+        # server = pywsgi.WSGIServer(('0.0.0.0', 5000), app)
+        # server.serve_forever(threaded=True)
     except Exception as e:
         traceback.print_exc(file=open('error.txt', 'a+'))
         print(e)