Общие массивы

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

Создаёт общий SharedArray типа бит T и размера 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}(...)

Создаёт общий SharedArray, поддерживаемый файлом 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, все индексы должны быть одинаково быстрыми для каждого процесса.