国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

from os import path as osPath, getcwd, mkdir
...
def __init__(self):
    ...
    self.cfg = self.initCfg()

def initCfg(self):
        cfg = {}
        # 代理，沒有可不用設(shè)置
        # cfg["proxies"] = "127.0.0.1:61274"
        # 加載圖片列表
        filename = "list.txt"
        if osPath.exists(filename):
            with open(filename, "r") as f:
                cfg["picList"] = f.read().strip().split("
")
        # 設(shè)置圖片的保存位置
        current_folder = getcwd()
        cfg["pic_temp"] = osPath.join( current_folder, "pic_temp")
        if not osPath.isdir( cfg["pic_temp"] ):
            mkdir(cfg["pic_temp"])
        return cfg

p = Process(target = startServiceP, args = ( self.GuiQueue, self.ServiceQueue, self.cfg ))

    點(diǎn)我下載圖片
    

在服務(wù)進(jìn)程ServiceEvent里添加一個(gè)方法getPicByList()

def getPicByList(self, msg):
        # 為圖片創(chuàng)建占位圖
        imgidList = self.__creatPlaceholderImg()
        for imgid in imgidList:
            picHttp = self.cfg["picList"].pop(0)
            file_name = picHttp.split("/")[-1]
            file_path = osPath.join( self.cfg["pic_temp"], file_name )
            # 圖片下載完成后需要執(zhí)行的任務(wù)
            _GuiRecvMsgDict = {
                "fun" : "setImgBg",
                "msg" : {"id":imgid,"fpath":file_path}
            }
            if not osPath.isfile(file_path):
                # 將下載任務(wù)動態(tài)添加到協(xié)程循環(huán)中
                self.__run_coroutine_threadsafe(
                    {"id": imgid,"http": picHttp,"fpath": file_path},
                    _GuiRecvMsgDict
                )
            else:
                self.__putGui( "setImgBg", {"id":imgid,"fpath":file_path} )

當(dāng)用戶點(diǎn)擊下載圖片的按鈕后會執(zhí)行到這個(gè)方法，為了更好的體驗(yàn)，在圖片下載之前先為其占據(jù)了空間，可以在其上顯示loading動畫，更重要的一點(diǎn)是，通過它可以控制圖片的顯示順序，因?yàn)橛脜f(xié)程下載圖片，你無法預(yù)知完成的順序...

def __creatPlaceholderImg(self):
        # 先創(chuàng)建5個(gè)占位圖
        html = ""
        imgidList = []
        time_now = ""
        for i in range(0, 5):
            time_now = "-".join( ( str(i), str(time()) ) )
            # 儲存圖片的id
            imgidList.append( time_now )
            html += self.html % ( time_now )
        self.__putGui("creatPlaceholderImg", html)
        return imgidList

之后就到了動態(tài)創(chuàng)建協(xié)程的部分了

def __run_coroutine_threadsafe(self, data, _GuiRecvMsgDict):
        asyncio.run_coroutine_threadsafe(self.dld.stream_download(
            data,
            _GuiRecvMsgDict
        ), self.new_loop)

但在正式介紹run_coroutine_threadsafe()之前，我們需要先開啟一個(gè)協(xié)程循環(huán)

但我們已經(jīng)開啟了一個(gè)用于處理隊(duì)列的循環(huán)了，沒辦法再開一個(gè)（也不排除是咱太菜），于是另開了一個(gè)線程專來處理協(xié)程

class ServiceEvent(object):
    """服務(wù)進(jìn)程"""
    def __init__(self, _GuiQueue, cfg):
        ...
        # 主線程中創(chuàng)建一個(gè)事件循環(huán)
        self.new_loop = asyncio.new_event_loop()
        self.dld = AsyncioDownload( self.new_loop, self.GuiQueue, self.proxies )

class AsyncioDownload(object):
    """使用協(xié)程下載圖片"""
    def __init__(self, loop, _GuiRecvMsg, proxies=None ):
        self.GuiRecvMsg = _GuiRecvMsg
        self._session = None
        self.loop = loop
        self.prox = "".join(("http://", proxies)) if proxies else proxies
        self.timeout = 10
        # 啟動一個(gè)線程，傳遞主線程中創(chuàng)建的事件循環(huán)
        t = Thread(target=self.start_loop, args=(self.loop,))
        t.setDaemon(True)    # 設(shè)置子線程為守護(hù)線程
        t.start()

    def start_loop(self, loop):
        # 啟動事件循環(huán)
        asyncio.set_event_loop(loop)
        loop.run_forever()

    def __session(self):
        if self._session is None:
            self._session = aiohttp.ClientSession(loop=self.loop)
        return self._session

    async def stream_download(self, d, _GuiRecvMsgDict):
        try:
            client = self.__session()
            async with client.get( d["http"], proxy=self.prox, timeout=self.timeout) as response:
                if response.status != 200:
                    print("error")
                    return
                # 保存圖片到本地
                if not osPath.isfile(d["fpath"]):
                    with open(d["fpath"], "ab") as file:
                        while True:
                            chunk = await response.content.read(1024)
                            if not chunk:
                                break
                            file.write(chunk)
                # 圖片下載完成后告知主線程
                self.GuiRecvMsg.put(_GuiRecvMsgDict)
        except asyncio.TimeoutError:
            pass

最后，主進(jìn)程獲得圖片的id及路徑，顯示到窗口中

function setImgBg( d ){
    var div = $(div[imgid="{d.id}"]);
    if(div){
        div.post( ::this.style#background-image = "url(" + d.fpath + ")" );
    }
}

源碼

總結(jié)：

完成這個(gè)項(xiàng)目使用了

多進(jìn)程 ---- 后臺服務(wù)

多線程 ---- 事件循環(huán)

協(xié)程 ---- IO操作

相對一個(gè)單純的爬蟲腳本來說，還是有點(diǎn)復(fù)雜的，尤其是交互，難怪這么多人不愿意寫界面...

雖然還有不足，但本次項(xiàng)目的內(nèi)容就到這了。

謝謝。

• 上一篇：Simplest Linear Regression on Keras Framework
• 下一篇：Python3爬蟲下載pdf（二）

fobnn

男|高級講師

我要關(guān)注 我要私信

TA的文章

閱讀更多

• 畢業(yè)設(shè)計(jì) - 題目：基于單片機(jī)的錄音器設(shè)計(jì)與實(shí)現(xiàn) - 物聯(lián)網(wǎng) 嵌入式

  閱讀 1677·2021-11-17 09:33

• 雖然中國注冊人沒有答復(fù)，但還是保住了WithU.com的所有權(quán)

  閱讀 3541·2021-11-16 11:40

• 前端知識雜談

  閱讀 3063·2019-08-30 11:23

• 前端工具【0】—— Emmet插件

  閱讀 1055·2019-08-29 16:36

• 挑逗Bootstrap4源代碼 - Grid篇（下）

  閱讀 2472·2019-08-29 13:23

• 好文 - 收藏集 - 掘金

  閱讀 1746·2019-08-29 12:59

• CSS3如何實(shí)現(xiàn)0.5邊框

  閱讀 1550·2019-08-29 12:42

• 圖解CSS3 讀書筆記——選擇器

  閱讀 1987·2019-08-28 18:22

最新活動