BarrierTakeMany

classe final pública BarrierTakeMany

Pega um determinado número de elementos concluídos de uma barreira.

Esta operação concatena tensores de componentes de elementos completos ao longo da 0ª dimensão para formar um tensor de componente único.

Os elementos saem da barreira quando estão completos e na ordem em que foram colocados na barreira. A saída dos índices fornece informações sobre o lote em que cada elemento foi originalmente inserido na barreira.

Classes aninhadas

aula BarreiraTakeMany.Options Atributos opcionais para BarrierTakeMany

Métodos Públicos

Barreira estáticaTakeMany.Options
permitirSmallBatch (booleano permitirSmallBatch)
barreira estáticaTakeMany
create (Escopo do escopo , identificador do operando <String>, Operando <Integer> numElements, List<Class<?>> componentTypes, Opções... opções)
Método de fábrica para criar uma classe que envolve uma nova operação BarrierTakeMany.
Saída <Longa>
índices ()
Um tensor unidimensional de índices, com comprimento num_elems.
Saída <String>
chaves ()
Um tensor unidimensional de chaves, com comprimento num_elements.
Barreira estáticaTakeMany.Options
timeoutMs (tempo limite longo)
Lista< Saída <?>>
valores ()
Um tensor qualquer dimensional por componente em um elemento de barreira.
Barreira estáticaTakeMany.Options
waitForIncomplete (booleano waitForIncomplete)

Métodos herdados

Métodos Públicos

público estático BarrierTakeMany.Options permitirSmallBatch (Booleano permitirSmallBatch)

Parâmetros
permitirSmallBatch Permitir retornar menos de num_elements itens se a barreira já estiver fechada.

public static BarrierTakeMany create ( Escopo escopo, Operando <String> identificador, Operando <Integer> numElements, List<Class<?>> componentTypes, Opções... opções)

Método de fábrica para criar uma classe que envolve uma nova operação BarrierTakeMany.

Parâmetros
escopo escopo atual
lidar A alça para uma barreira.
numElementos Um tensor de elemento único contendo o número de elementos a serem obtidos.
tipos de componentes O tipo de cada componente em um valor.
opções carrega valores de atributos opcionais
Devoluções
  • uma nova instância de BarrierTakeMany

índices <Long> de saída pública ()

Um tensor unidimensional de índices, com comprimento num_elems. Esses índices referem-se ao lote em que os valores foram colocados na barreira (começando com MIN_LONG e aumentando a cada BarrierInsertMany).

Chaves <String> de saída pública ()

Um tensor unidimensional de chaves, com comprimento num_elements.

público estático BarrierTakeMany.Options timeoutMs (Long timeoutMs)

Parâmetros
tempo limiteMs Se a fila estiver vazia, esta operação será bloqueada por até timeout_ms milissegundos. Nota: Esta opção ainda não é suportada.

Lista pública< Saída <?>> valores ()

Um tensor qualquer dimensional por componente em um elemento de barreira. Todos os valores têm comprimento num_elements na 0ª dimensão.

público estático BarrierTakeMany.Options waitForIncomplete (booleano waitForIncomplete)