К книге
Рассказы о математике с примерами на языках Python и CСтраница 11
100%
Страница 11
11

Увы, в более сложных задачах такого прироста реально не бывает (в последнем примере очень короткий код, который видимо полностью помещается в кеш-памяти процессора), но на некоторое улучшение быстродействия можно рассчитывать. Хотя переписывание программы - это крайний случай, сначала целесообразно поискать стандартные библиотеки, которые возможно уже решают данную задачу. К примеру, следующий код на языке Python вычисляет сумму элементов массива за 0.1с:

a = xrange(1000001)

s = 0

for x in a:

s += x

print(s)

Можно использовать встроенную функцию sum:

a = range(1000001)

s = sum(a)

print(s)

Данный код выполняется за 0.02 секунды, т.е. в 5 раз быстрее первого варианта.

Вопрос, что выбрать, на самом деле, не так однозначен - язык Си быстрее, но и сложнее в использовании. Но если заранее известно, что задача состоит в обработке большого набора чисел (например поиск простых чисел или магических квадратов), то может быть более целесообразным сразу писать программу на Си или С++, в принципе это не намного сложнее, а работать программа будет быстрее. С другой стороны, при наличии в программе сложной логики или структур данных, написание ее на Python будет гораздо проще. Поэтому, на практике целесообразно прототип программы делать на языке Python, и только в том случае, если проблема быстродействия становится критичной и не решаемой доступными средствами, переходить на более низкоуровневые средства разработки.

Кстати, для тех, кто захочет максимально широко использовать Python в математических расчетах, крайне рекомендуется ознакомиться с библиотекой numpy, она является стандартом де-факто для всех серьезных расчетов.

Приложение 3 - Пример оптимизации программы

Рассмотрим практический пример сравнения скорости вычислений на Python. Допустим, есть массив целых чисел, для каждого числа надо найти количество его делителей.

Функцию нахождения делителей числа будем использовать “как есть”, без какой-либо оптимизации: перебираем все числа, если число делится без остатка, увеличиваем счетчик.

def get_dividers(n):

divs = 0

for i in xrange(1, n+1):

if n % i == 0:

divs += 1

return divs

Рассмотрим способы решения задачи. Исходные данные: массив целых чисел:

values = [41212317, 4672313, 4342311, 46512319, 51212317, 5672313, 5342311, 56512319]

Способ-1

Решение “в лоб” (заодно показан способ измерения времени выполнения).

import timeit

start_time = timeit.default_timer()

res = []

for v in values:

res.append(get_dividers(v))

print(res)

print("T =", timeit.default_timer() - start_time)

Время выполнения кода на компьютере с процессором Core i7: 10c.

Способ-2

Используем функцию map, позволяющую применить функцию сразу к массиву.

res = map(get_dividers, values)

print(list(res))

Время выполнения: те же 10с, пока мы выиграли разве что в краткости записи.

Способ-3

Используем многопоточность, класс multiprocessing.Pool, позволяющий разбить вычисления над массивом на несколько потоков.

p = multiprocessing.Pool(processes=4)

res = p.map(get_dividers, values)

print(list(res))

Время выполнения: 3.7с, что уже лучше. Интересно, что несмотря на разбивку на 4 процесса, реальное время выполнения уменьшилось лишь вдвое. Многопоточные вычисления - достаточно дорогостоящая в плане накладных расходов операция, множество ресурсов процессора тратится на синхронизацию и передачу данных между процессами.

Способ-4

Используем библиотеку параллельных вычислений ipyparallel. Она имеет большие возможности, даже позволяет производить вычисления параллельно на нескольких компьютерах.

Перед тестом запустим сервер вычислений на том же компьютере, командой

ipcluster start -n 4.

Код запуска вычислений не намного больше:

import ipyparallel as ipp

rc = ipp.Client()

dv = rc[:]

res = dv.map_sync(get_dividers, values)

print(list(res))

Как можно видеть, синтаксис практически тот же, библиотека сама делает всю работу по распараллеливанию вычислений. Впрочем, время выполнения практически то же - 3.4с, ведь мы выполняем вычисления на одном компьютере. При желании читатели могут повторить эксперимент с несколькими компьютерами самостоятельно, описание процесса есть на странице http://ipyparallel.readthedocs.io/en/latest/process.html.

Способ-5

Как говорилось еще в начале книги, Python - это интерпретатор, и код выполняется достаточно медленно. Кардинально повысить скорость можно, используя компиляцию программы перед выполнением, что было реализовано в библиотеке Numba. Ее можно поставить, выполнив команду “pip install numba”.

Метод очень простой и эффективный, и практически не требует изменения кода: всего лишь добавляем перед описанием функции ключевое слово @numba.jit.

Данный код скопирован в отдельный файл Appendix3_test2.py:

import numba

@numba.jit

def get_dividers(n):

divs = 0

for i in xrange(1, n+1):

if n % i == 0:

divs += 1

return divs

Запуск ничем не отличается от предыдущего варианта:

import Appendix3_test2 as test2

res = map(test2.get_dividers, values)

print(list(res))

Время выполнения в обычном, однопоточном режиме - 1.5с. Это уже заметная разница!

И наконец, повторяем вышеописанные процедуры, но функцию заменяем на новый вариант.

Многопоточность:

p = multiprocessing.Pool(processes=8)

res = p.map(test2.get_dividers, values)

Время выполнения: 1.04c.

И последний вариант, библиотека ipyparallel:

res = dv.map_sync(test2.get_dividers, values)

print(list(res))

Время выполнения: 0.57c.

Таким образом, по сравнению с изначальным вариантом, мы увеличили скорость расчетов почти в 20 раз, при этом сам код изменять или переписывать практически не пришлось.

В целом, можно предложить следующий алгоритм оптимизации вычислений на языке Python:

1) По возможности, стараться использовать встроенные функции, имеющиеся в библиотеках math, numpy и др. Они уже написаны на C или C++, и работают максимально эффективно.

2) Использовать библиотеку numba, указав в начале функции префикс @numba.jit. Это самый простой и “безболезненный” способ, он чуть увеличит время запуска программы, но скорость расчетов может вырасти в 10 раз. Правда, этот способ не поможет, если код уже состоит только из вызовов встроенных функций из п1. Если же код содержит циклы, условия, другие проверки, то скорость выполнения вырастет значительно.

3) Если скорость расчета нужно еще увеличить, переходим к более тяжелой артиллерии - многопоточности. Используя библиотеку multiprocessing, можно разбить вычисления на несколько ядер процессора - это может увеличить скорость в 2-4 раза. Но важно иметь в виду, что межпроцессное взаимодействие - сама по себе довольно-таки долгая операция, так что делать ее имеет смысл для действительно долго выполняющихся фрагментов кода. Небольшая функция, вызывающаяся много раз в разных потоках, будет работать в итоге даже медленнее за счет дополнительных “накладных расходов”.

4) И наконец, если скорость расчета нужно еще увеличить, можно разбить вычисления на несколько компьютеров в сети, используя библиотеку ipyparallel. Как и в предыдущем случае, заранее следует продумать структуру алгоритма, чтобы производить вычисления крупными блоками, это сделает метод более эффективным.

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

Заключение

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

Продолжение следует.

Обо найденных неточностях или дополнениях просьба писать на электронную почту dmitryelj@gmail.com. Наличие новой версии можно проверить на странице https://cloud.mail.ru/public/4SGE/oE2EGEWnp.

Предыдущая главаГлава 11 из 11К книге