建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
創(chuàng)新互聯(lián)Python教程：python多線程處理大量文件數(shù)據(jù)
在python中，我們會(huì)遇到處理大量文件數(shù)據(jù)的時(shí)候。如果我們用for循環(huán)順序處理，處理文件數(shù)據(jù)效率額很低，這時(shí)我們就可以使用我們的多線程來(lái)處理多個(gè)超大的文件數(shù)據(jù)。
讓客戶滿意是我們工作的目標(biāo)，不斷超越客戶的期望值來(lái)自于我們對(duì)這個(gè)行業(yè)的熱愛(ài)。我們立志把好的技術(shù)通過(guò)有效、簡(jiǎn)單的方式提供給客戶，將通過(guò)不懈努力成為客戶在信息化領(lǐng)域值得信任、有價(jià)值的長(zhǎng)期合作伙伴，公司提供的服務(wù)項(xiàng)目有：域名與空間、雅安服務(wù)器托管、營(yíng)銷(xiāo)軟件、網(wǎng)站建設(shè)、修武網(wǎng)站維護(hù)、網(wǎng)站推廣。
第一步：導(dǎo)入import threading 模塊
import threading
第二步：使用多線程可以同時(shí)打開(kāi)并運(yùn)行多個(gè)數(shù)據(jù)
#! /usr/bin/env python
#encoding=utf-8
import threading
import time
from Queue import Queue
def readFile():
file_object = open('/opt/dev/python/list.dat')
global queue
for line in file_object:
queue.put(line)
class Consumer(threading.Thread):
def run(self):
global queue
while queue.qsize() > 0:
msg = self.name + '消費(fèi)了 '+queue.get()
print msg
time.sleep(0.01)
queue = Queue()
def main():
readFile()
for i in range(5):
c = Consumer()
c.start()
if __name__ == '__main__':
main()
以上就是用python多線程處理大量數(shù)據(jù)的演示代碼，如果有需要處理大量文件的小伙伴，可以嘗試使用多線程，會(huì)方便很多哦~
（推薦操作系統(tǒng)：windows7系統(tǒng)、Python 3.9.1，DELL G3電腦。）
當(dāng)前文章：創(chuàng)新互聯(lián)Python教程：python多線程處理大量文件數(shù)據(jù)
網(wǎng)站URL：http://m.fisionsoft.com.cn/article/djghpgi.html
