Объединённые массивы

SharedArray{T}(dims::NTuple; init=false, pids=Int[])
SharedArray{T,N}(...)

Создаёт объединённый массив типа SharedArray и размера dims для процессов, указанных в pids, которые должны находиться на одном хосте. Если N указано вызовом SharedArray{T,N}(dims), то N должно соответствовать длине dims.

Если pids не указано, объединённый массив будет отображаться для всех процессов на текущем хосте, включая мастер-процесс. Однако, localindices и indexpids будут относиться только к рабочим процессам. Это упрощает распределение работы, позволяя рабочим процессам выполнять вычисления, а мастер-процессу действовать в качестве драйвера.

Если указана функция init типа initfn(S::SharedArray), она будет вызвана для всех участвующих рабочих процессов.

Объединённый массив остаётся валидным до тех пор, пока ссылка на объект SharedArray существует на узле, создавшем отображение.

SharedArray{T}(filename::AbstractString, dims::NTuple, [offset=0]; mode=nothing, init=false, pids=Int[])
SharedArray{T,N}(...)

Создаёт объединённый массив, поддерживаемый файлом filename, с типом элементов T (должен быть типом битов) и размером dims, для процессов, указанных в pids, которые должны находиться на одном хосте. Этот файл отображается в памяти хоста, что влечёт за собой следующие последствия:

• Данные массива должны быть представлены в двоичном формате (например, формат ASCII, как CSV, не поддерживается)

• Любые изменения, которые вы вносите в значения массива (например, A[3] = 0), также изменят значения в файле на диске

Если pids не указано, объединённый массив будет отображаться для всех процессов на текущем хосте, включая мастер-процесс. Однако, localindices и indexpids будут относиться только к рабочим процессам. Это упрощает распределение работы, позволяя рабочим процессам выполнять вычисления, а мастер-процессу действовать в качестве драйвера.

mode должен быть одним из "r", "r+", "w+", или "a+", и по умолчанию равен "r+" если файл, указанный в filename уже существует, или "w+" если нет. Если указана функция init типа initfn(S::SharedArray), она вызывается для всех участвующих рабочих процессов. Вы не можете указать функцию init если файл не может быть изменён.

offset позволяет пропустить указанное количество байтов в начале файла.

SharedVector

Одномерный SharedArray.

SharedMatrix

Двумерный SharedArray.

procs(S::SharedArray)

Получение вектора процессов, отображающих объединённый массив.

sdata(S::SharedArray)

Возвращает фактический объект Array поддерживающий S.

indexpids(S::SharedArray)

Возвращает индекс текущего рабочего процесса в списке рабочих процессов, отображающих SharedArray (т.е. в том же списке, что и возвращаемый procs(S)), или 0, если SharedArray не отображается локально.

localindices(S::SharedArray)

Возвращает диапазон, описывающий "стандартные" индексы, обрабатываемые текущим процессом. Этот диапазон следует интерпретировать в смысле линейной индексации, т.е. как поддиапазон 1:length(S). В многопроцессорных средах возвращает пустой диапазон в родительском процессе (или любом процессе, для которого indexpids возвращает 0).

Стоит отметить, что localindices существует только для удобства, и вы можете распределять работу по массиву между рабочими процессами любым способом. Для SharedArray, все индексы должны быть одинаково быстрыми для каждого рабочего процесса.