DataflowBlock 클래스

정의

네임스페이스:

System.Threading.Tasks.Dataflow

어셈블리:

System.Threading.Tasks.Dataflow.dll

데이터 흐름 블록으로 작업하기 위한 static(Visual Basic의 경우 Shared) 메서드 집합을 제공합니다.

public ref class DataflowBlock abstract sealed

public static class DataflowBlock

type DataflowBlock = class

Public Module DataflowBlock

상속

Object

DataflowBlock

설명

참고

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를 실행합니다.

메서드

AsObservable<TOutput>(ISourceBlock<TOutput>)	IObservable<T> 위에 새 ISourceBlock<TOutput> 추상화를 만듭니다.
AsObserver<TInput>(ITargetBlock<TInput>)	ITargetBlock<TInput> 위에 새 IObserver<T> 추상화를 만듭니다.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)	세 개의 데이터 흐름 소스를 모니터링하여 제공된 처리기 중에서 데이터를 가장 먼저 사용할 수 있도록 하는 소스를 호출합니다.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)	세 개의 데이터 흐름 소스를 모니터링하여 제공된 처리기 중에서 데이터를 가장 먼저 사용할 수 있도록 하는 소스를 호출합니다.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)	두 개의 데이터 흐름 소스를 모니터링하여 제공된 처리기 중에서 데이터를 가장 먼저 사용할 수 있도록 하는 소스를 호출합니다.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)	두 개의 데이터 흐름 소스를 모니터링하여 제공된 처리기 중에서 데이터를 가장 먼저 사용할 수 있도록 하는 소스를 호출합니다.
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)	대상 및 소스를 단일 전파자로 캡슐화합니다.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	ISourceBlock<TOutput>을 지정된 ITargetBlock<TInput>에 연결합니다.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	지정된 필터를 사용하여 ISourceBlock<TOutput>을 지정된 ITargetBlock<TInput>에 연결합니다.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	지정된 필터를 사용하여 ISourceBlock<TOutput>을 지정된 ITargetBlock<TInput>에 연결합니다.
NullTarget<TInput>()	제공된 모든 메시지를 동기적으로 수락하고 삭제하는 대상 블록을 가져옵니다.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	사용 가능한 출력에 대한 소스를 비동기적으로 모니터링하는 Task<TResult>을 제공합니다.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	사용 가능한 출력에 대한 소스를 비동기적으로 모니터링하는 Task<TResult>을 제공합니다.
Post<TInput>(ITargetBlock<TInput>, TInput)	ITargetBlock<TInput>에 항목을 게시합니다.
Receive<TOutput>(ISourceBlock<TOutput>)	지정된 소스에서 값을 동기적으로 받습니다.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	지정된 소스에서 값을 동기적으로 받고 작업을 취소하는 토큰을 제공합니다.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	지정된 소스에서 값을 동기적으로 받으며 최적의 시간 초과 기간을 관찰합니다.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	지정된 원본에서 값을 동기적으로 받으면서 작업을 취소하는 토큰을 제공하고 최적의 시간 초과 간격을 관찰합니다.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	IAsyncEnumerable<T> 원본에서 모든 데이터를 수신할 수 있는 해당 데이터를 만듭니다.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	지정된 소스에서 값을 비동기적으로 받습니다.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	지정된 소스에서 값을 비동기적으로 받고 작업을 취소하는 토큰을 제공합니다.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	지정된 소스에서 값을 비동기적으로 받으며 최적의 시간 초과 기간을 관찰합니다.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	지정된 원본에서 값을 비동기적으로 받으면서 작업을 취소하는 토큰을 제공하고 최적의 시간 초과 간격을 관찰합니다.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	대상 메시지 블록에 메시지를 비동기적으로 제공하며, 연기를 허용합니다.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	대상 메시지 블록에 메시지를 비동기적으로 제공하며, 연기를 허용합니다.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	ISourceBlock<TOutput>에서 항목을 비동기적으로 받으려고 시도합니다.