python-multithreading

    1熱度

    1回答

    我在代碼中有幾個工作線程執行某些工作。來自作品的數據被收集到一個擁有這些信息的小類中。這個類放入隊列中以便在主線程中處理。 GC何時收集此類? 短西頭excample: def run(in_q, out_q): lp = lpClass() # Do work and add info in class workToDo = in_q.get_nowait()

    0熱度

    1回答

    我正在使用「Inotify」記錄在目錄(此處爲tmp)中創建文件或文件夾時的事件。這裏的例子在串行過程中完成了這項工作。意思是,所有文件的創建都是依次處理的。 import logging import inotify.adapters _DEFAULT_LOG_FORMAT = '%(asctime)s - %(name)s - %(levelname)s - %(message)s'

    1熱度

    1回答

    我目前遇到線程加入問題。我有一個函數根據給定的參數執行一系列操作。有一個「開始」按鈕,將啓動該函數,並且該函數作爲一個線程運行。 相同的按鈕變成了一個「停止」按鈕,單擊時會停止該功能。不幸的是,線程似乎並沒有結束。 相關的代碼是在這裏...請注意,「self.stop_com_loop」用來結束線程... 任何意見將是巨大的。 def Start_Com(self): """

    1熱度

    2回答

    立即返回我已經寫了一對夫婦在python Twitter的刮削器,並在寫另一個腳本,讓他們即使他們遭受超時,斷開跑步等 我目前的解決方案是如下: 每一刮片文件中有一個doScrape/1功能,這將啓動刮板,一旦運行,如: def doScrape(logger): try: with DBWriter(logger=logger) as db: logger.l

    8熱度

    3回答

    我試圖解決的問題如下: 我有一個文件名列表trainimgs的文件名。我與它的capacity=len(trainimgs)和min_after_dequeue=0定義的 tf.RandomShuffleQueue。 對於指定的epochlimit,此tf.RandomShuffleQueue預計將填充trainimgs次數。 許多線程預計並行工作。每個線程從tf.RandomShuffleQue

    0熱度

    4回答

    我需要每n秒運行一個進程。我認爲Threading.timer是最好的方法。但是當我運行我的命令時,它不會每隔n秒運行一次,但是會反覆運行,比給定的n少很多,並且循環不可停止。這是我的代碼: #!/usr/bin/python import threading import time brake = 10 k = int(5) def printit(): for x i

    0熱度

    1回答

    藉此範例程序: from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor def fun(xx): for _ in range(10): y = 1 x = xx while x > 0: y = (y * x) % 1000000007

    0熱度

    1回答

    我有一個文件夾(「/ home/samples /」),並且文件由另一個應用程序連續寫入。我的腳本是: def multiThreadedSend(): for root, subdirs, files in os.walk("/home/samples/"): fileList = sorted(files) queue = Queue.Queue()

    4熱度

    1回答

    我正在學習Python的線程模塊,並寫了下面的代碼,以幫助自己瞭解 from Queue import Queue import threading lock = threading.Lock() MAX_THREADS = 8 q = Queue() count = 0 # some i/o process def io_process(x): pass # pr

    1熱度

    1回答

    我正在研究一個腳本,它可以擦除數千個不同的網頁。由於這些網頁通常是不同的(有不同的網站),我使用多線程來加快抓取速度。 編輯:SIMPLE簡短說明 ------- 我加載300周的網址(HTMLS)在300名員工中的一個池。由於html的大小是可變的,有時候,大小的總和可能太大,python會增加:internal buffer error : Memory allocation failed :