Взять список из списка списков

Здравствуйте.
Требуется разделить список на заданное количество частей. Для дальнейшей передачи части списка в виде аргумента для выполнения функции на заданном ядре.

Для 4 ядерного компьютера из списка
lst = [x for x in range(1,16)]
Надо получить список
[1,2,3,4] для первого ядра
[5,6,7,8] для второго ядра
[9,10,11,12] для третьего ядра
[13,14,15] для четвертого ядра

В данный момент диапазон выполнения функции я указываю для каждого ядра в ручную, но хотелось бы сделать это по-человечески. В моем примере в последнем списке элементов меньше чем в остальных, для случаев когда количество элементов списка не кратно количеству ядер.
Я делю списки на равные части данным методом.

lst = [x for x in range(1,16)]
parts = multiprocessing.cpu_count()
parting(lst,parts)

Вывод: [[1,2,3,4], [5,6,7,8][9,10,11,12][13,14,15]]

Вопрос в том каким образом мне взять отдельно каждый из списков, не указывая его диапазон в ручную. Рассматриваю вариант генерации новых переменных.
lst1 = [1,2,3,4]
lst2
lst3
lst4
Но думаю что есть варианты реализации гораздо проще и логичнее, для этого сюда и обратился. Спасибо.

0

Сообщение от SprootGeryndi lst = [x for x in range(1,16)]

list(range(1,16))

Сообщение от SprootGeryndi Вопрос в том каким образом мне взять отдельно каждый из списков, не указывая его диапазон в ручную.

в цикле и двигая счетчик по 4, нет? можно даже не хардкодить 4,а передавать в функцию цпу_каунт, чтобы динамически делил.

1

import multiprocessing

lst = list(range(500))

def function1(i):
----for x in range(1, i):
--------for y in range(1, i):
------------x**y

def call_function(lst1):

----for i in lst1:
--------function1(i)


def parting_cores (core_number, proc):

----lst1 = []

----lst1.append(lst[core_number: len(lst)+1:cores])

----return(lst1)


if __name__ == "__main__":

----processes = []

----cores = multiprocessing.cpu_count()

----for x in range(cores):
--------p = multiprocessing.Process(target=call_func tion, args=(parting_cores(x, cores)))
--------processes.append(p)
--------p.start()


----for x in processes:
--------p.join()






Спасибо за ваш ответ, решил подобным методом. Описание идет снизу вверх. Циклом создаем количество процессов, равное количеству ядер. В виде аргумента для заданной функции, подставляется функция, равномерно распределяющая значения массива для каждого ядра с помощью среза изначального списка, начинающегося с индекса списка, равному ядру, и шагом, равным количеству ядер. Таким образом каждое ядро получает максимально равный объем работы, так как полученный список идет не по порядку, а берется равномерная выборка значений для каждого ядра от начала и до конца массива. Call_function и function1 в данном случае просто тяжелая задача в качестве примера работы. Хардкода удалось избежать. Выполнение данного алгоритма на 1 ядре занимает 298секунд, на 8 ядрах 48 секунд.

0