Многопроцессорность / многопоточность 3 вложенных цикла в Python 2.7 - PullRequest
Новая
       7

Многопроцессорность / многопоточность 3 вложенных цикла в Python 2.7

0 голосов
/ 24 мая 2018

У меня есть фрагмент следующего кода: 

for x in xrange(100,14000):
    for y in xrange(0,3000):
        for z in xrange(0,700):
            operationg_tag = "%s-%s-%s" % (x,y,z)
            operation_code = ....

            and more bunch of code is running here on the tag generated above

Я выполняю этот код на быстром хорошем оборудовании, но природа этих циклов медленная, потому что в Multiprocessing / Multithredding * не выполняется

Требуется около 0,4 секунд, чтобы выполнить необходимый код для каждого тега.

Как я могу реализовать многопроцессорность / многопоточность в этих вложенных циклах, чтобы она работала быстрее?на какую из петель я должен нацелиться?

1 Ответ

0 голосов
/ 24 мая 2018

Прервите первый цикл как 3 процесса, 

    def func(start, final):
         for x in xrange(start, final):
              for y in xrange(0,3000):
                   for z in xrange(0,700):
        operationg_tag = "%s-%s-%s" % (x,y,z)
        operation_code = ....
    def main():
        total = 14000
        div_total = int(14000 / 3)
        rest_div_total = 14000%3
        t1 = multiprocessing.Process(target = func,name = "", args=(100, div_total)
        t2 = multiprocessing.Process(target = func,name = "", args=(div_total, div_total*2)
        t3 = multiprocessing.Process(target = func,name = "", args=(div_total*2, div_total*3 + rest_div_total + 1)
        list_threads = [t1,t2,t3]
        for i in list_threads:
           i.start()
        for i in list_threads:
           i.join()

    if __name__ == "__main__":
        main()

Вы можете создать больше процессов, если хотите, но 3 Это хорошо.

...