Shared Arrays

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

Construye un SharedArray de un tipo de bits T y tamaño dims a través de los procesos especificados por pids - todos los cuales deben estar en el mismo host. Si N se especifica al llamar a SharedArray{T,N}(dims), entonces N debe coincidir con la longitud de dims.

Si pids se deja sin especificar, el array compartido se mapeará a través de todos los procesos en el host actual, incluyendo el maestro. Sin embargo, localindices e indexpids solo se referirán a los procesos de trabajo. Esto facilita que el código de distribución de trabajo utilice trabajadores para el cálculo real, con el proceso maestro actuando como un controlador.

Si se especifica una función init del tipo initfn(S::SharedArray), se llama en todos los trabajadores participantes.

El array compartido es válido mientras exista una referencia al objeto SharedArray en el nodo que creó el mapeo.

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

Construye un SharedArray respaldado por el archivo filename, con tipo de elemento T (debe ser un tipo de bits) y tamaño dims, a través de los procesos especificados por pids - todos los cuales deben estar en el mismo host. Este archivo se mapea en la memoria del host, con las siguientes consecuencias:

• Los datos del array deben estar representados en formato binario (por ejemplo, un formato ASCII como CSV no puede ser soportado)
• Cualquier cambio que realices en los valores del array (por ejemplo, A[3] = 0) también cambiará los valores en el disco

Si pids se deja sin especificar, el array compartido se mapeará a través de todos los procesos en el host actual, incluyendo el maestro. Sin embargo, localindices e indexpids solo se referirán a los procesos de trabajo. Esto facilita que el código de distribución de trabajo utilice trabajadores para el cálculo real, con el proceso maestro actuando como un controlador.

mode debe ser uno de "r", "r+", "w+", o "a+", y por defecto es "r+" si el archivo especificado por filename ya existe, o "w+" si no. Si se especifica una función init del tipo initfn(S::SharedArray), se llama en todos los trabajadores participantes. No puedes especificar una función init si el archivo no es escribible.

offset te permite omitir el número especificado de bytes al principio del archivo.

SharedVector

Un SharedArray unidimensional.

SharedMatrix

Un SharedArray bidimensional.

procs(S::SharedArray)

Obtiene el vector de procesos que mapean el arreglo compartido.

sdata(S::SharedArray)

Devuelve el objeto Array real que respalda a S.

indexpids(S::SharedArray)

Devuelve el índice del trabajador actual en la lista de trabajadores que mapean el SharedArray (es decir, en la misma lista devuelta por procs(S)), o 0 si el SharedArray no está mapeado localmente.

localindices(S::SharedArray)

Devuelve un rango que describe los "índices" predeterminados que debe manejar el proceso actual. Este rango debe interpretarse en el sentido de indexación lineal, es decir, como un sub-rango de 1:length(S). En contextos de múltiples procesos, devuelve un rango vacío en el proceso padre (o en cualquier proceso para el cual indexpids devuelve 0).

Vale la pena enfatizar que localindices existe puramente como una conveniencia, y puedes dividir el trabajo en el arreglo entre los trabajadores de la manera que desees. Para un SharedArray, todos los índices deberían ser igualmente rápidos para cada proceso trabajador.