Flask之request實現思想


Flask之全局的request,每次請求不一樣的,是如何實現的???

了解flask的都知道,每次請求request的對象,是不一樣的,但request是全局對象,內部怎么做到的?在我們請求的時候,uwgsi會起一個線程,然而線程之間數據是可以共享的 ,flask是這樣的思想,根據線程號,假設有一個全局的大字典 global_dict = {},根據線程號,這樣存儲 :

 global_dict {'線程號1':{key:val,key1:val1},
              '線程號2':{key:val,key1:val1},
             '線程號3':{key:val,key1:val1},...
             }

來要數據的時候根據你的線程號來區分:

初級版本

###############1,多線程寫同一個數據,會導致錯亂
from threading import Thread
import time
aaa = -1
def task(arg):
    global lqz
    lqz = arg
    time.sleep(2)
    print(lqz)

for i in range(10):
    t = Thread(target=task,args=(i,))
    t.start()
打印出都是 9
----------------------------------------
根據線程號存放值
from threading import get_ident,Thread
import time
storage = {}
#{'線程id':{value:1},'線程id':{value:2}....}
def set(k,v):
    ident = get_ident()
    if ident in storage:
        storage[ident][k] = v
    else:
        storage[ident] = {k:v}
def get(k):
    ident = get_ident()
    return storage[ident][k]
def task(arg):
    set('val',arg)
    v = get('val')
    print(v)

for i in range(10):
    t = Thread(target=task,args=(i,))
    t.start()
    

flask源碼思想版本:

try:
    from greenlet import getcurrent as get_ident  #將協程號的函數也as成get_ident,統一接口,
except Exception as e:
    from threading import get_ident  #獲取線程號

class Local(object):
    def __init__(self):

        self.__dict__['glo_dic'] = {}     #  方法1 ,類所有的屬性  方法都在這里,反射也是看__dict__里面有沒有,將全局的字典放在這
        # self.__class__.__dict__['glo_dic'] = {}  一開始我想放在類里的,發現類的__dict__只能看不能放進去,你也可以在Local里直接寫
        #object.__setattr__(self,'glo_dic',{}) 調用object的__detattr__

    def __setattr__(self, key, value):
        if get_ident() in self.glo_dic:   #判斷線程號是否在里面
            self.glo_dic[get_ident()][key] = value
        else:
            self.glo_dic[get_ident()] = {key:value}
    def __getattr__(self, item):
        return self.glo_dic[get_ident()].get(item)

    def __getitem__(self, item):
        return self.__getattr__(item)
    def __setitem__(self, key, value):
        self.__setattr__(key,value)

a = Local()

def f1(i):
    a['val'] = i   #調用__setitem__
    time.sleep(2)
    print(a.val)   #調用__getattr__   
if __name__ == '__main__':
    li = []
    for i in range(10):
        li.append(Thread(target=f1,args=(i,)))   
    for t in li:
        t.start()  #起10個先線程,

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM