Запись нескольких файлов одновременно - PullRequest
0 голосов
/ 02 июля 2019

Я пытаюсь записать 100 файлов параллельно.

Существует список data и элементы в нем должны быть записаны в отдельные файлы. Я пробовал concurrent.futures, но это не сработало (ничего в файлах).

data = ['a','b','c']

def write2file(i):
    outhandles[i].write(data[i])

with concurrent.futures.ThreadPoolExecutor(max_workers=10) as executor:
    executor.map(write2file,range(s,e))

Ожидаемые результаты:

file1.txt:'a',
file2.txt:'b',
...

1 Ответ

0 голосов
/ 02 июля 2019

Поместите ваши данные в объект Queue, затем используйте потоки для параллельного извлечения элементов из очереди. Это должно помочь и поточно-ориентированно в зависимости от вашей логики и от того, как вы комбинируете файлы.

...