Простая проблема Python: самый быстрый поразрядный XOR на буферах данных

Проблема:

Выполните поразрядный XOR на двух равных размерных буферах. Буферы потребуются, чтобы быть Python str введите, так как это - традиционно тип для буферов данных в Python. Возвратите результирующее значение как a str. Сделайте это максимально быстро.

Исходные данные составляют два 1 мегабайт (2 ** 20 байтов) строки.

Проблема состоит в том, чтобы существенно разбить мой неэффективный алгоритм с помощью Python или существующих сторонних модулей Python (ослабленные правила: или создайте свой собственный модуль.) Крайние увеличения бесполезны.

from os import urandom
from numpy import frombuffer,bitwise_xor,byte

def slow_xor(aa,bb):
    a=frombuffer(aa,dtype=byte)
    b=frombuffer(bb,dtype=byte)
    c=bitwise_xor(a,b)
    r=c.tostring()
    return r

aa=urandom(2**20)
bb=urandom(2**20)

def test_it():
    for x in xrange(1000):
        slow_xor(aa,bb)
51
задан user213060 4 February 2010 в 04:59
поделиться

10 ответов

Первая попытка

Использование встроенных функций scipy.weave и SSE2 дает незначительное улучшение. Первый вызов немного медленнее, так как код необходимо загрузить с диска и кэшировать, последующие вызовы выполняются быстрее:

import numpy
import time
from os import urandom
from scipy import weave

SIZE = 2**20

def faster_slow_xor(aa,bb):
    b = numpy.fromstring(bb, dtype=numpy.uint64)
    numpy.bitwise_xor(numpy.frombuffer(aa,dtype=numpy.uint64), b, b)
    return b.tostring()

code = """
const __m128i* pa = (__m128i*)a;
const __m128i* pend = (__m128i*)(a + arr_size);
__m128i* pb = (__m128i*)b;
__m128i xmm1, xmm2;
while (pa < pend) {
  xmm1 = _mm_loadu_si128(pa); // must use unaligned access 
  xmm2 = _mm_load_si128(pb); // numpy will align at 16 byte boundaries
  _mm_store_si128(pb, _mm_xor_si128(xmm1, xmm2));
  ++pa;
  ++pb;
}
"""

def inline_xor(aa, bb):
    a = numpy.frombuffer(aa, dtype=numpy.uint64)
    b = numpy.fromstring(bb, dtype=numpy.uint64)
    arr_size = a.shape[0]
    weave.inline(code, ["a", "b", "arr_size"], headers = ['"emmintrin.h"'])
    return b.tostring()

Вторая попытка

Принимая во внимание комментарии, я повторно просмотрел код, чтобы выяснить, может ли копирование избегать. Оказывается, я неправильно прочитал документацию по строковому объекту, так что вот моя вторая попытка:

support = """
#define ALIGNMENT 16
static void memxor(const char* in1, const char* in2, char* out, ssize_t n) {
    const char* end = in1 + n;
    while (in1 < end) {
       *out = *in1 ^ *in2;
       ++in1; 
       ++in2;
       ++out;
    }
}
"""

code2 = """
PyObject* res = PyString_FromStringAndSize(NULL, real_size);

const ssize_t tail = (ssize_t)PyString_AS_STRING(res) % ALIGNMENT;
const ssize_t head = (ALIGNMENT - tail) % ALIGNMENT;

memxor((const char*)a, (const char*)b, PyString_AS_STRING(res), head);

const __m128i* pa = (__m128i*)((char*)a + head);
const __m128i* pend = (__m128i*)((char*)a + real_size - tail);
const __m128i* pb = (__m128i*)((char*)b + head);
__m128i xmm1, xmm2;
__m128i* pc = (__m128i*)(PyString_AS_STRING(res) + head);
while (pa < pend) {
    xmm1 = _mm_loadu_si128(pa);
    xmm2 = _mm_loadu_si128(pb);
    _mm_stream_si128(pc, _mm_xor_si128(xmm1, xmm2));
    ++pa;
    ++pb;
    ++pc;
}
memxor((const char*)pa, (const char*)pb, (char*)pc, tail);
return_val = res;
Py_DECREF(res);
"""

def inline_xor_nocopy(aa, bb):
    real_size = len(aa)
    a = numpy.frombuffer(aa, dtype=numpy.uint64)
    b = numpy.frombuffer(bb, dtype=numpy.uint64)
    return weave.inline(code2, ["a", "b", "real_size"], 
                        headers = ['"emmintrin.h"'], 
                        support_code = support)

Разница в том, что строка размещена внутри кода C. Невозможно выровнять его по 16-байтовой границе, как того требуют инструкции SSE2, поэтому невыровненные области памяти в начале и в конце копируются с использованием побайтного доступа.

Входные данные в любом случае передаются с использованием массивов numpy, потому что weave настаивает на копировании объектов Python str в std :: string s. frombuffer не копирует, так что это нормально, но память не выровнена по 16 байтам, поэтому нам нужно использовать _mm_loadu_si128 вместо более быстрого _mm_load_si128 .

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

Тайминги

Что касается таймингов, запись slow_xor в первом редактировании относилась к моей улучшенной версии (встроенный побитовый xor, uint64 ), я устранил эту путаницу. slow_xor относится к коду из исходных вопросов. Все тайминги рассчитаны на 1000 запусков.

  • slow_xor : 1,85 с (1x)
  • Fast_slow_xor : 1,25 с (1,48x)
  • inline_xor : 0,95 с (1,95x)
  • inline_xor_nocopy : 0,32 s (5.78x)

Код был скомпилирован с использованием gcc 4.4.3, и я убедился, что компилятор действительно использует инструкции SSE.

36
ответ дан 7 November 2019 в 09:59
поделиться

Если вы хотите сделать быстрые операции по типам данных массива, то вам следует попробовать Cython (Cython.org). Если вы дадите ему правильные декларации, он должен иметь возможность компилировать до чистого C-кода.

1
ответ дан 7 November 2019 в 09:59
поделиться

Легкое ускорение - использовать более крупный «кусок»:

def faster_xor(aa,bb):
    a=frombuffer(aa,dtype=uint64)
    b=frombuffer(bb,dtype=uint64)
    c=bitwise_xor(a,b)
    r=c.tostring()
    return r

с UINT64 также импортируется из Numpy , конечно. I Timeit Это при 4 миллисекундах, VS 6 миллисекунд для версии байта .

10
ответ дан 7 November 2019 в 09:59
поделиться

Вы можете попробовать симметричную разницу битегов шалфета.

http://www.sagemath.org/doc/reference/sage/misc/bitset.html

0
ответ дан 7 November 2019 в 09:59
поделиться

Самый быстрый способ (по низкой стороне) будет делать то, что макс. S рекомендуется. Реализуйте его в C.

Поддерживающий код для этой задачи должен быть довольно простым для записи. Это только одна функция в модуле создает новую строку и выполнение XOR. Это все. Когда вы реализовали один модуль, подобный тому, что это просто сделать код как шаблон. Или вы даже возьмете модуль, реализованный от кого-то еще, который реализует простой модуль улучшения для Python и просто выкинуть все, что не нужно для вашей задачи.

Реальная сложная часть - это просто, делая правильное значение RefCounter. Но однажды понял, как это работает, это управляется - также, поскольку задача под рукой действительно проста (выделяет некоторую память, и вернуть его - парам не нужно касаться (Ref-Wise)).

0
ответ дан 7 November 2019 в 09:59
поделиться

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

Нижний код показывает, что даже на моем скромном компьютере Python может Xor «AA» (1 МБ) и «BB» (1 МБ) в «C» (1 МБ) в тысячу раз (всего 3 ГБ) в . Серьезно, насколько больше улучшении вы хотите? Особенно от интерпретированного языка! 80% времени было потрачено называть «из бурки» и «TOSTRING». Фактический XOR-ING завершен в других 20% времени. На 3 ГБ за 2 секунды вам было бы трудно улучшить это , существенно даже просто используя мемкпи в с.

В случае, если это был реальный вопрос, а не просто скрываться о Python, ответ - это код, чтобы минимизировать количество, количество и частоту преобразований вашего типа, таких как «из« избивки »и« TOSTRING ». Фактическое уже быстро молниена.

from os import urandom
from numpy import frombuffer,bitwise_xor,byte,uint64

def slow_xor(aa,bb):
    a=frombuffer(aa,dtype=byte)
    b=frombuffer(bb,dtype=byte)
    c=bitwise_xor(a,b)
    r=c.tostring()
    return r

bb=urandom(2**20)
aa=urandom(2**20)

def test_it():
    for x in xrange(1000):
    slow_xor(aa,bb)

def test_it2():
    a=frombuffer(aa,dtype=uint64)
    b=frombuffer(bb,dtype=uint64)
    for x in xrange(1000):
        c=bitwise_xor(a,b);
    r=c.tostring()    

test_it()
print 'Slow Complete.'
#6 seconds
test_it2()
print 'Fast Complete.'
#under 2 seconds

В любом случае, выше, выше «TEST_IT2» достигает точно такое же количество XOR-ing, как «test_it», но, но в 1/5 времени. 5x Улучшение скорости должно квалифицироваться как «существенный», нет?

7
ответ дан 7 November 2019 в 09:59
поделиться

Вот мои результаты для cython

slow_xor   0.456888198853
faster_xor 0.400228977203
cython_xor 0.232881069183
cython_xor_vectorised 0.171468019485

Векторизация в cython сокращает примерно на 25% цикл for на моем компьютере, однако тратится больше половины времени построение строки Python (оператор return ) - я не думаю, что дополнительной копии можно избежать (юридически), поскольку массив может содержать нулевые байты.

Недопустимым способом было бы передать строку Python и изменить ее на месте, что удвоило бы скорость функции.

xor.py

from time import time
from os import urandom
from numpy import frombuffer,bitwise_xor,byte,uint64
import pyximport; pyximport.install()
import xor_

def slow_xor(aa,bb):
    a=frombuffer(aa,dtype=byte)
    b=frombuffer(bb,dtype=byte)
    c=bitwise_xor(a,b)
    r=c.tostring()
    return r

def faster_xor(aa,bb):
    a=frombuffer(aa,dtype=uint64)
    b=frombuffer(bb,dtype=uint64)
    c=bitwise_xor(a,b)
    r=c.tostring()
    return r

aa=urandom(2**20)
bb=urandom(2**20)

def test_it():
    t=time()
    for x in xrange(100):
        slow_xor(aa,bb)
    print "slow_xor  ",time()-t
    t=time()
    for x in xrange(100):
        faster_xor(aa,bb)
    print "faster_xor",time()-t
    t=time()
    for x in xrange(100):
        xor_.cython_xor(aa,bb)
    print "cython_xor",time()-t
    t=time()
    for x in xrange(100):
        xor_.cython_xor_vectorised(aa,bb)
    print "cython_xor_vectorised",time()-t

if __name__=="__main__":
    test_it()

xor_.pyx

cdef char c[1048576]
def cython_xor(char *a,char *b):
    cdef int i
    for i in range(1048576):
        c[i]=a[i]^b[i]
    return c[:1048576]

def cython_xor_vectorised(char *a,char *b):
    cdef int i
    for i in range(131094):
        (<unsigned long long *>c)[i]=(<unsigned long long *>a)[i]^(<unsigned long long *>b)[i]
    return c[:1048576]
17
ответ дан 7 November 2019 в 09:59
поделиться

Самый быстрый битовый XOR - "^". Я могу набрать это намного быстрее, чем "bitwise_xor" ;-)

.
4
ответ дан 7 November 2019 в 09:59
поделиться

Насколько сильно вам нужен ответ в виде строки? Обратите внимание, что метод c.tostring () должен скопировать данные из c в новую строку, поскольку строки Python неизменяемы (и c изменчив). Python 2.6 и 3.1 имеют тип bytearray , который действует как str ( байтов в Python 3.x), за исключением того, что он изменяемый.

Другая оптимизация заключается в использовании параметра out для bitwise_xor , чтобы указать, где сохранить результат.

На моей машине я получаю

slow_xor (int8): 5.293521 (100.0%)
outparam_xor (int8): 4.378633 (82.7%)
slow_xor (uint64): 2.192234 (41.4%)
outparam_xor (uint64): 1.087392 (20.5%)

с кодом в конце этого сообщения. В частности, обратите внимание, что метод, использующий предварительно выделенный буфер, в два раза быстрее, чем создание нового объекта (при работе с 4-байтовыми ( uint64 ) фрагментами). Это согласуется с тем, что более медленный метод выполняет две операции на фрагмент (xor + copy) с более быстрым 1 (просто xor).

Кроме того, FWIW, a ^ b эквивалентно bitwise_xor (a, b) , а a ^ = b эквивалентно bitwise_xor (а, б, а) .

Итак, 5-кратное ускорение без записи каких-либо внешних модулей :)

from time import time
from os import urandom
from numpy import frombuffer,bitwise_xor,byte,uint64

def slow_xor(aa, bb, ignore, dtype=byte):
    a=frombuffer(aa, dtype=dtype)
    b=frombuffer(bb, dtype=dtype)
    c=bitwise_xor(a, b)
    r=c.tostring()
    return r

def outparam_xor(aa, bb, out, dtype=byte):
    a=frombuffer(aa, dtype=dtype)
    b=frombuffer(bb, dtype=dtype)
    c=frombuffer(out, dtype=dtype)
    assert c.flags.writeable
    return bitwise_xor(a, b, c)

aa=urandom(2**20)
bb=urandom(2**20)
cc=bytearray(2**20)

def time_routine(routine, dtype, base=None, ntimes = 1000):
    t = time()
    for x in xrange(ntimes):
        routine(aa, bb, cc, dtype=dtype)
    et = time() - t
    if base is None:
        base = et
    print "%s (%s): %f (%.1f%%)" % (routine.__name__, dtype.__name__, et,
        (et/base)*100)
    return et

def test_it(ntimes = 1000):
    base = time_routine(slow_xor, byte, ntimes=ntimes)
    time_routine(outparam_xor, byte, base, ntimes=ntimes)
    time_routine(slow_xor, uint64, base, ntimes=ntimes)
    time_routine(outparam_xor, uint64, base, ntimes=ntimes)
1
ответ дан 7 November 2019 в 09:59
поделиться

Сравнение производительности: numpy, Cython, C, Fortran, Boost.Python (pyublas)

| function               | time, usec | ratio | type         |
|------------------------+------------+-------+--------------|
| slow_xor               |       2020 |   1.0 | numpy        |
| xorf_int16             |       1570 |   1.3 | fortran      |
| xorf_int32             |       1530 |   1.3 | fortran      |
| xorf_int64             |       1420 |   1.4 | fortran      |
| faster_slow_xor        |       1360 |   1.5 | numpy        |
| inline_xor             |       1280 |   1.6 | C            |
| cython_xor             |       1290 |   1.6 | cython       |
| xorcpp_inplace (int32) |        440 |   4.6 | pyublas      |
| cython_xor_vectorised  |        325 |   6.2 | cython       |
| inline_xor_nocopy      |        172 |  11.7 | C            |
| xorcpp                 |        144 |  14.0 | boost.python |
| xorcpp_inplace         |        122 |  16.6 | boost.python |
#+TBLFM: $3=@2$2/$2;%.1f

Для воспроизведения результатов загрузите http://gist.github.com/353005 и введите make (для установки зависимостей введите: sudo apt-get install build-essential python-numpy python-scipy cython gfortran , зависимости для Boost.Python , pyublas не включены, так как для их работы требуется ручное вмешательство)

Где:

И xor_ $ type_sig () :

! xorf.f90.template
subroutine xor_$type_sig(a, b, n, out)
  implicit none
  integer, intent(in)             :: n
  $type, intent(in), dimension(n) :: a
  $type, intent(in), dimension(n) :: b
  $type, intent(out), dimension(n) :: out

  integer i
  forall(i=1:n) out(i) = ieor(a(i), b(i))

end subroutine xor_$type_sig

Он используется из Python следующим образом:

import xorf # extension module generated from xorf.f90.template
import numpy as np

def xor_strings(a, b, type_sig='int64'):
    assert len(a) == len(b)
    a = np.frombuffer(a, dtype=np.dtype(type_sig))
    b = np.frombuffer(b, dtype=np.dtype(type_sig))
    return getattr(xorf, 'xor_'+type_sig)(a, b).tostring()

xorcpp_inplace () (Boost.Python, pyublas):

xor.cpp :

#include <inttypes.h>
#include <algorithm>
#include <boost/lambda/lambda.hpp>
#include <boost/python.hpp>
#include <pyublas/numpy.hpp>

namespace { 
  namespace py = boost::python;

  template<class InputIterator, class InputIterator2, class OutputIterator>
  void
  xor_(InputIterator first, InputIterator last, 
       InputIterator2 first2, OutputIterator result) {
    // `result` migth `first` but not any of the input iterators
    namespace ll = boost::lambda;
    (void)std::transform(first, last, first2, result, ll::_1 ^ ll::_2);
  }

  template<class T>
  py::str 
  xorcpp_str_inplace(const py::str& a, py::str& b) {
    const size_t alignment = std::max(sizeof(T), 16ul);
    const size_t n         = py::len(b);
    const char* ai         = py::extract<const char*>(a);
    char* bi         = py::extract<char*>(b);
    char* end        = bi + n;

    if (n < 2*alignment) 
      xor_(bi, end, ai, bi);
    else {
      assert(n >= 2*alignment);

      // applying Marek's algorithm to align
      const ptrdiff_t head = (alignment - ((size_t)bi % alignment))% alignment;
      const ptrdiff_t tail = (size_t) end % alignment;
      xor_(bi, bi + head, ai, bi);
      xor_((const T*)(bi + head), (const T*)(end - tail), 
           (const T*)(ai + head),
           (T*)(bi + head));
      if (tail > 0) xor_(end - tail, end, ai + (n - tail), end - tail);
    }
    return b;
  }

  template<class Int>
  pyublas::numpy_vector<Int> 
  xorcpp_pyublas_inplace(pyublas::numpy_vector<Int> a, 
                         pyublas::numpy_vector<Int> b) {
    xor_(b.begin(), b.end(), a.begin(), b.begin());
    return b;
  }
}

BOOST_PYTHON_MODULE(xorcpp)
{
  py::def("xorcpp_inplace", xorcpp_str_inplace<int64_t>);     // for strings
  py::def("xorcpp_inplace", xorcpp_pyublas_inplace<int32_t>); // for numpy
}

Он используется из Python следующим образом:

import os
import xorcpp

a = os.urandom(2**20)
b = os.urandom(2**20)
c = xorcpp.xorcpp_inplace(a, b) # it calls xorcpp_str_inplace()
36
ответ дан 7 November 2019 в 09:59
поделиться
Другие вопросы по тегам:

Похожие вопросы: