python多進(jìn)程重復(fù)加載的解決方式

更新時(shí)間：2019年12月13日 10:27:33 作者：ShellCollector

今天小編就為大家分享一篇python多進(jìn)程重復(fù)加載的解決方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

flask多進(jìn)程會(huì)引起重復(fù)加載，

解決方法：把耗資源的加載挪到函數(shù)里面或者類里面，就不會(huì)重復(fù)加載資源了。

測(cè)試發(fā)現(xiàn)，不是flask引起的，是多進(jìn)程會(huì)引起重復(fù)加載python文件。

把flask注釋掉，也會(huì)重復(fù)加載。

# autotrade/__init__.py
# __init__.py 定義全局的app路由
# 然后將其他模塊由app裝飾后的函數(shù)導(dǎo)入，flask即可識(shí)別所有的請(qǐng)求入口
import time
 
from flask import Flask
from multiprocessing import Process
 
# 配置全局app
 
# 導(dǎo)入index中定義的所有函數(shù)
# from autotrade.server.index import *
print("import will repeat")
def run_index():
  print("run_index once")
  app = Flask(__name__)
  # 啟動(dòng)web服務(wù)器，使用多線程方式，接收所有http請(qǐng)求
  app.run(host='0.0.0.0', port=5000, threaded=True,debug=False)
 
def run_orders():
  # 啟動(dòng)查詢交易程序
  while True:
    print('執(zhí)行相應(yīng)的交易程序')
    time.sleep(3)
 
def main():
  # 主程序
  # 創(chuàng)建子進(jìn)程
  jobs = []
  jobs.append(Process(target=run_index))
  # jobs.append(Process(target=run_orders))
  # 啟動(dòng)子進(jìn)程
  for job in jobs:
    job.start()
 
  # 等待子進(jìn)程結(jié)束返回
  for job in jobs:
    job.join()
 
if __name__ == '__main__':
  # run_index()
  main()

一般情況，把需要加載的封裝到函數(shù)或者類中就可以了，

但是有一個(gè)例外：就是SQLAlchemy

必須在py文件中實(shí)例化，

from flask_login import LoginManager
from flask_mail import Mail
from flask_socketio import SocketIO
from flask_migrate import Migrate
from flask_rq2 import RQ
from flask_wtf.csrf import CSRFProtect

from monitor.common.storage import LocalStorage, QiniuStorage, ObjectStorage
import config.global_var as gl_var
# from monitor.common.es_search import ESearchEngine

QINIU_AVAILABLE = gl_var.get_value("qiniu_available")
OSS_AVAILABLE = gl_var.get_value("oss_available")
REDIS_URI = gl_var.get_value("redis_uri")
BASEDIR = gl_var.get_value("basedir")
sbdwl = gl_var.get_value("sbdwl")


class Redis(object):

  def __init__(self):
    self._db = None

  def init_app(self, uri=REDIS_URI):
    self._db = _redis.Redis.from_url(uri)

  @property
  def db(self):
    return self._db

print("import foundation")

import threading
class Singleton(object):
  _instance_lock=threading.Lock()
  def __init__(self):
    pass
    # import time
    # print("sleep")
    # time.sleep(1)
  def __new__(cls, *args, **kwargs):
    if not hasattr(Singleton,"_instance"):
      with Singleton._instance_lock:
        if not hasattr(Singleton,"_instance"):
          print("create _instance----------------------------")
          Singleton._instance=object.__new__(cls,*args,**kwargs)

          app = Flask(__name__)
          Singleton._instance.db = SQLAlchemy(app)
          Singleton._instance.login_manager = LoginManager()

解決方法：把啟動(dòng)換到一個(gè)新文件，然后在函數(shù)中調(diào)用這個(gè)文件，import也放在函數(shù)內(nèi)部。

以上這篇python多進(jìn)程重復(fù)加載的解決方式就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: