BatchBlock<T> 클래스
정의
중요
일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.
배열로 입력을 일괄 처리하는 데이터 흐름 블록을 제공합니다.
generic <typename T>
public ref class BatchBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<T, cli::array <T> ^>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ITargetBlock<T>
public sealed class BatchBlock<T> : System.Threading.Tasks.Dataflow.IPropagatorBlock<T,T[]>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<T[]>, System.Threading.Tasks.Dataflow.ISourceBlock<T[]>, System.Threading.Tasks.Dataflow.ITargetBlock<T>
type BatchBlock<'T> = class
interface IPropagatorBlock<'T, 'T[]>
interface ITargetBlock<'T>
interface IDataflowBlock
interface ISourceBlock<'T[]>
interface IReceivableSourceBlock<'T[]>
type BatchBlock<'T> = class
interface IDataflowBlock
interface IPropagatorBlock<'T, 'T[]>
interface ISourceBlock<'T[]>
interface ITargetBlock<'T>
interface IReceivableSourceBlock<'T[]>
Public NotInheritable Class BatchBlock(Of T)
Implements IPropagatorBlock(Of T, T()), IReceivableSourceBlock(Of T()), ISourceBlock(Of T()), ITargetBlock(Of T)
형식 매개 변수
- T
일괄 처리될 데이터 형식을 지정합니다.
- 상속
-
BatchBlock<T>
- 구현
설명
참고
TPL 데이터 흐름 라이브러리(System.Threading.Tasks.Dataflow 네임스페이스)는 .NET과 함께 배포되지 않습니다. Visual Studio에서 System.Threading.Tasks.Dataflow 네임스페이스를 설치하려면 프로젝트를 열고, 프로젝트 메뉴에서 NuGet 패키지 관리를 선택한 후, System.Threading.Tasks.Dataflow
패키지를 온라인으로 검색합니다. 또는 .NET Core CLI를 사용하여 설치하려면 dotnet add package System.Threading.Tasks.Dataflow
를 실행합니다.
생성자
BatchBlock<T>(Int32) |
지정된 배치 크기를 사용하여 새 BatchBlock<T>을 초기화합니다. |
BatchBlock<T>(Int32, GroupingDataflowBlockOptions) |
지정된 배치 크기, 거부 옵션 및 블록 옵션을 사용하여 새 BatchBlock<T>을 초기화합니다. |
속성
BatchSize |
이 BatchBlock<T>에서 생성한 배치의 크기를 가져옵니다. |
Completion |
비동기 작업 및 데이터 흐름 블록의 완료를 나타내는 Task를 가져옵니다. |
OutputCount |
이 블록에서 받을 수 있는 출력 항목의 개수를 가져옵니다. |
메서드
Complete() |
IDataflowBlock에 대한 신호를 통해 더 이상의 메시지를 받거나 생성할 수 없으며 추가로 지연된 메시지를 사용하면 안 됩니다. |
Equals(Object) |
지정된 개체가 현재 개체와 같은지 확인합니다. (다음에서 상속됨 Object) |
GetHashCode() |
기본 해시 함수로 작동합니다. (다음에서 상속됨 Object) |
GetType() |
현재 인스턴스의 Type을 가져옵니다. (다음에서 상속됨 Object) |
LinkTo(ITargetBlock<T[]>, DataflowLinkOptions) |
ISourceBlock<TOutput>을 지정된 ITargetBlock<TInput>에 연결합니다. |
MemberwiseClone() |
현재 Object의 단순 복사본을 만듭니다. (다음에서 상속됨 Object) |
ToString() |
이 IDataflowBlock 인스턴스의 형식 지정된 이름을 나타내는 문자열을 반환합니다. |
TriggerBatch() |
현재 대기 중이거나 연기된 항목 수가 BatchBlock<T>보다 작으면 BatchSize을 트리거하여 일괄 처리 작업을 시작합니다. |
TryReceive(Predicate<T[]>, T[]) |
IReceivableSourceBlock<TOutput>에서 사용 가능한 출력 항목을 비동기적으로 받으려고 시도합니다. |
TryReceiveAll(IList<T[]>) |
IReceivableSourceBlock<TOutput>에서 모든 사용 가능한 항목을 비동기적으로 받으려고 시도합니다. |
명시적 인터페이스 구현
IDataflowBlock.Fault(Exception) |
Faulted 상태에서 IDataflowBlock가 완료되도록 합니다. |
ISourceBlock<T[]>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<T[]>, Boolean) |
이 ISourceBlock<TOutput>에서 이전에 제공한 DataflowMessageHeader를 받아 사용하기 위해 연결된 ITargetBlock<TInput>에 의해 호출됩니다. |
ISourceBlock<T[]>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<T[]>) |
이 ITargetBlock<TInput>에 의해 이전에 예약한 DataflowMessageHeader를 해제하기 위해 연결된 ISourceBlock<TOutput>에 의해 호출됩니다. |
ISourceBlock<T[]>.ReserveMessage(DataflowMessageHeader, ITargetBlock<T[]>) |
이 ITargetBlock<TInput>에 의해 이전에 제공한 DataflowMessageHeader를 예약하기 위해 연결된 ISourceBlock<TOutput>에 의해 호출됩니다. |
ITargetBlock<T>.OfferMessage(DataflowMessageHeader, T, ISourceBlock<T>, Boolean) |
메시지를 ITargetBlock<TInput>에 제공하며 대상에서 메시지를 선택적으로 사용하거나 연기할 수 있습니다. |