BarrierTakeMany

classe finale pubblica BarrierTakeMany

Prende il numero indicato di elementi completati da una barriera.

Questa operazione concatena i tensori dei componenti degli elementi completati lungo la dimensione 0 per creare un tensore a componente singolo.

Gli elementi escono dalla barriera quando sono completi e nell'ordine in cui sono stati posizionati nella barriera. L'output degli indici fornisce informazioni sul lotto in cui ciascun elemento è stato originariamente inserito nella barriera.

Classi nidificate

classe BarrierTakeMany.Options Attributi facoltativi per BarrierTakeMany

Metodi pubblici

BarrierTakeMany.Options statico
consentireSmallBatch (permesso booleanoSmallBatch)
Barriera statica TakeMany
create ( ambito ambito , handle dell'operando <String>, operando <Integer> numElements, List<Class<?>> ComponentTypes, Opzioni... opzioni)
Metodo factory per creare una classe che racchiude una nuova operazione BarrierTakeMany.
Uscita <Lungo>
indici ()
Un tensore unidimensionale di indici, con lunghezza num_elems.
Uscita <Stringa>
chiavi ()
Un tensore unidimensionale di chiavi, con lunghezza num_elements.
BarrierTakeMany.Options statico
timeoutMs (TimeoutM lungo)
Elenco< Uscita <?>>
valori ()
Un tensore qualsiasi dimensionale per componente in un elemento barriera.
BarrierTakeMany.Options statico
waitForIncomplete (waitForIncomplete booleano)

Metodi ereditati

Metodi pubblici

pubblico statico BarrierTakeMany.OptionsallowSmallBatch ( allowSmallBatch booleano)

Parametri
consentireSmallBatch Consenti di restituire meno di num_elements elementi se la barriera è già chiusa.

public static BarrierTakeMany create ( scope scope, operando <String> handle, operando <Integer> numElements, List<Class<?>> componenteTypes, Opzioni... opzioni)

Metodo factory per creare una classe che racchiude una nuova operazione BarrierTakeMany.

Parametri
scopo ambito attuale
maniglia La maniglia di una barriera.
numElementi Un tensore a elemento singolo contenente il numero di elementi da prendere.
componentiTipi Il tipo di ciascun componente in un valore.
opzioni trasporta valori di attributi opzionali
ritorna
  • una nuova istanza di BarrierTakeMany

Indici pubblici di output <Long> ()

Un tensore unidimensionale di indici, con lunghezza num_elems. Questi indici si riferiscono al batch in cui i valori sono stati inseriti nella barriera (a partire da MIN_LONG e aumentando con ogni BarrierInsertMany).

Tasti <String> di output pubblici ()

Un tensore unidimensionale di chiavi, con lunghezza num_elements.

public static BarrierTakeMany.Options timeoutMs (TimeoutMs lunghi)

Parametri
timeoutMs Se la coda è vuota, questa operazione verrà bloccata per un massimo di timeout_ms millisecondi. Nota: questa opzione non è ancora supportata.

elenco pubblico< Output <?>> valori ()

Un tensore qualsiasi dimensionale per componente in un elemento barriera. Tutti i valori hanno lunghezza num_elements nella dimensione 0.

public static BarrierTakeMany.Options waitForIncomplete (booleano waitForIncomplete)