Приложение для проверки файлов Python с многопоточностью

Question

Как использовать многопоточность в этом коде и ограничить поток; Пример 4 темы.

import os
import glob
from pymongo import Connection
from gridfs import GridFS

db = Connection().microfilm
fs = GridFS(db)

def scandirs(path):
    for currentFile in glob.glob( os.path.join(path, '*') ):
        if os.path.isdir(currentFile):
            print 'Entering directory: ' + currentFile
            scandirs(currentFile)

        base, ext = os.path.splitext(currentFile)
        if ( ext == '.tif'):
                print "Processing file: " + currentFile
                fName = os.path.basename(currentFile)
                with open(currentFile) as gfsFile:
                        oid = fs.put(gfsFile, content_type="image/tiff", filename=fName)

scandirs('./')

Заранее спасибо.

Answer 1

Создайте пул (список) объектов Thread размером n, используйте is_alive , чтобы проверить, завершен ли какой-либо из них, и тогда вы сможете назначить в нем новое сканирование каталогов.Также вы должны создать подкласс класса Thread и определить метод run для адаптации к вашей проблеме, подробности о том, как это сделать, приведены в документации.

Answer 2

сначала импортируйте Threading, затем Threading. init () какую часть вы хотите добавить в имя потока, это run () (это переопределенный метод базового класса Thread) или Thread (target = "ваш потокfunction ", args = []) вызвать метод запуска с объектом потока.