替换高级线程管理器

main.py

@@ -12,6 +12,7 @@ import jimit as ji
 import json
 
 import os
+import threading
 from flask import g
 
 from models import Utils
@@ -92,7 +93,6 @@ def r_before_request():
 # noinspection PyBroadException
 try:
     db.init_conn_mysql()
-    thread.start_new_thread(db.keepalived_mysql, ())
     db.init_conn_redis()
 
     app.register_blueprint(boot_job_blueprint)
@@ -139,17 +139,30 @@ if __name__ == '__main__':
             # 父进程退出时，会清理所有提前退出的子进程的环境。所以这里无需对子进程做等待操作。
             # 即：即使子进程提前退出，且因父进程没有做wait处理，使其变成了僵尸进程。但当父进程退出时，会对因其所产生的僵尸进程做统一清理操作。
 
-            thread.start_new_thread(EventProcessor.launch, ())
-            Utils.thread_counter += 1
+            threads = []
+            t_ = threading.Thread(target=EventProcessor.launch, args=())
+            threads.append(t_)
 
-            thread.start_new_thread(Init.pub_sub_ping_pong, ())
-            Utils.thread_counter += 1
+            t_ = threading.Thread(target=Init.pub_sub_ping_pong, args=())
+            threads.append(t_)
+
+            for t in threads:
+                t.start()
 
             app.run(host=app.config['jimv_listen'], port=app.config['jimv_port'], use_reloader=False, threaded=True)
 
-            while Utils.thread_counter > 0:
+            while True:
+                if Utils.exit_flag:
+                    # 主线程即将结束
+                    break
                 time.sleep(1)
 
+            print 'fuck'
+
+            # 等待子线程结束
+            for t in threads:
+                t.join()
+
             print 'Main say bye-bye!'
 
     except:

models/event_processor.py

@@ -255,9 +255,7 @@ class EventProcessor(object):
     def launch(cls):
         while True:
             if Utils.exit_flag:
-                Utils.thread_counter -= 1
                 print 'Thread EventProcessor say bye-bye'
-                print 'Current thread_counter: ' + Utils.thread_counter.__str__()
                 return
 
             try:

models/initialize.py

@@ -100,9 +100,7 @@ class Init(object):
 
         while True:
             if Utils.exit_flag:
-                Utils.thread_counter -= 1
                 print 'Thread pub_sub_ping_pong say bye-bye'
-                print 'Current thread_counter: ' + Utils.thread_counter.__str__()
                 return
 
             time.sleep(10)

models/utils.py

@@ -39,6 +39,7 @@ class Utils(object):
     @classmethod
     def signal_handle(cls, signum=0, frame=None):
         cls.exit_flag = True
+        raise RuntimeError('Shutdown app!')
 
     @staticmethod
     def dumps2response(func):

views_route_table.py

@@ -1,6 +1,7 @@
 #!/usr/bin/env python
 # -*- coding: utf-8 -*-
 
+
 from models.utils import add_rule_views
 from views import guest, disk, log, os_template