python之怎么使用線程池map()方法傳遞多參數(shù)list

這篇文章主要介紹“python之怎么使用線程池map()方法傳遞多參數(shù)list”的相關(guān)知識，小編通過實際案例向大家展示操作過程，操作方法簡單快捷，實用性強，希望這篇“python之怎么使用線程池map()方法傳遞多參數(shù)list”文章能幫助大家解決問題。

線程池map（）方法傳遞多參數(shù)list

之前通過threading.thread（）進行了助力接口的多線程并發(fā)，但是這個針對并發(fā)數(shù)量較少的時候比較好用，如果并發(fā)數(shù)量多，除了線程包協(xié)程這種處理方式的情況下，我們還可以采用線程池的方法。

線程池的實現(xiàn)通俗講就是把所有的任務(wù)放在了消息隊列里，開啟多個線程后執(zhí)行線程，但線程執(zhí)行結(jié)束后不會中斷線程任務(wù)，會從消息隊列內(nèi)繼續(xù)獲取線程任務(wù)進行線程執(zhí)行，這樣線程池就比多線程操作節(jié)省了很多創(chuàng)建線程與關(guān)閉線程的步驟，節(jié)約大部分資源與時間。

線程池并發(fā)需要引入模塊

import concurrent.futures

ThreadPoolExecutor 內(nèi)有兩種線程池方法 map()與submit()今天先說map()方法

他的語法為

 with concurrent.futures.ThreadPoolExecutor() as pool:
      res = pool.map(craw, uid_list)
      print(res)

• map()內(nèi)craw為方法名，這里方法命不帶()

• uid_list為方法參數(shù)，map()方法內(nèi)需要傳遞list數(shù)據(jù)類型

先看一下整體代碼

5000用戶并發(fā)助力

    def test_case_09(self):
        """5000用戶并發(fā)助力"""
        # 通過yaml配置文件封裝方法 獲取uid_list
        uid_list = YamlHandler(YamlThePath().number_new).get_uid_list()
        # add_ticket獲取5000賬號登陸狀態(tài)
        with concurrent.futures.ThreadPoolExecutor() as pool:
            pool.map(AccountAccess().add_ticket, uid_list)
        # 5000賬號線程池方法助力用戶
        with concurrent.futures.ThreadPoolExecutor() as pool:
            pool.map(PreheatMethod().help, [(uid, self.A, 1) for uid in uid_list])
        # 獲取用戶被助力次數(shù)
        response = PreheatMethod().init(self.A)
        print(f"當(dāng)前用戶被助力次數(shù) :{response['data']['userInfo']['helpedCount']}次")

再來看一下兩個接口的方法更好的感知一下

首先是獲取登陸狀態(tài)add_ticket

    def add_ticket(self, uid):
        """
        獲取單獨用戶t票
        :param uid: 單獨用戶uid
        :return:
        """
        self.data['url'] = ApiAddress().get_ticket
        self.data['host'] = ApiAddress().host
        self.params['uid'] = str(uid)
        self.params['type'] = 0
        self.data['params'] = json.dumps(self.params)
        res = r().post(url=ApiAddress().ticket, data=self.data)
        print(f'獲取t票結(jié)果：{uid}{res}')
        return uid

很簡單的一個接口請求 入?yún)⒅挥幸粋€uid，但是注意一下這里的uid不是list，他只是一個參數(shù)。

那么有的同學(xué)就會有疑問，map()內(nèi)傳遞的方法參數(shù)是一個uid內(nèi)容的list。

map()方法就是把你需要的參數(shù)存在list內(nèi)，通過遍歷的方式去請求你指定的接口。

這時候可能有的人又會問，因為我當(dāng)時也是這么問自己的，如果一個方法內(nèi)有多個參數(shù)，其中這些參數(shù)有的甚至都不是固定的內(nèi)容怎么辦。

咱們看一下另一個請求助力接口的方法

    def help(self, agrs):
        """
        助力用戶
        :param agrs: uid:當(dāng)前用戶uid to_uid:助力用戶uid count:助力次數(shù)
        :return:
        """
        uid, to_uid, count = agrs
        self.attrs['toUid'] = str(to_uid)
        self.attrs['count'] = count
        response = r().response(uid, self.code, "help", **self.attrs)
        logger.info(f'help response uid:{uid} to_uid:{to_uid}\n{response}')
        return response

沒錯，我們通過元組的方式傳遞到助力接口內(nèi)，通過元組內(nèi)的關(guān)鍵字位置分別給指定的元素賦值。

再線程池的代碼內(nèi)，我們通過列表推導(dǎo)式把uid_list內(nèi)的參數(shù)便利到你指定好的元組內(nèi)，當(dāng)然這里如果是多個參數(shù)，也可以用字典，把字典便利key與value當(dāng)作變化的參數(shù)，因為列表推導(dǎo)式給你返回的是list，所以我們把需要的參數(shù)放在元組內(nèi)，元組放在列表內(nèi)，這樣就可以對多參數(shù)的方法使用map()線程池進行并發(fā)了。

with concurrent.futures.ThreadPoolExecutor() as pool:
            pool.map(PreheatMethod().help, [(uid, self.A, 1) for uid in uid_list])

[(uid, self.A, 1) for uid in uid_list]

列表推導(dǎo)式獲取后大概就是下方的list數(shù)據(jù)內(nèi)容格式

關(guān)于“python之怎么使用線程池map()方法傳遞多參數(shù)list”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識，可以關(guān)注億速云行業(yè)資訊頻道，小編每天都會為大家更新不同的知識點。