AsyncPipeline 클래스

정의

네임스페이스:

Orleans.Runtime

어셈블리:

Orleans.Core.dll

패키지:

Microsoft.Orleans.Core v3.6.5

Source:

AsyncPipeline.cs

비동기 작업의 생성 속도를 제어할 수 있는 도우미 유틸리티 클래스입니다. 지정된 최대 용량까지 비동기 작업의 파이프라인을 유지하고 큐에 추가된 작업이 완료되지 않기 전에 파이프라인이 너무 깊어지면 호출 스레드를 차단합니다. 호출자에게 역압을 효과적으로 추가합니다. 이는 주로 제어된 부하 하에서 스트레스 테스트 조직에 유용하며 조직 코드 내에서 사용하면 안 됩니다.

public class AsyncPipeline : Orleans.Runtime.IPipeline

type AsyncPipeline = class
    interface IPipeline

Public Class AsyncPipeline
Implements IPipeline

상속

Object

AsyncPipeline

구현

IPipeline

생성자

AsyncPipeline()	용량이 DefaultCapacity와 같은 빈 AsyncPipeline을 생성합니다.
AsyncPipeline(Int32)	지정된 용량으로 빈 AsyncPipeline을 생성합니다.

필드

DEFAULT_CAPACITY

이 AsyncPipeline의 기본 용량입니다. 10과 같습니다.

속성

Capacity	이 비동기 파이프라인에 큐에 넣을 수 있는 최대 비동기 기내 작업 수입니다.
Count	현재 이 비동기 파이프라인에 큐에 넣은 항목 수입니다.

메서드

Add(Task)	이 AsyncPipeline에 새 작업을 추가합니다.
AddRange(IEnumerable<Task>)	이 AsyncPipeline에 작업 컬렉션을 추가합니다.
AddRange<T>(IEnumerable<Task<T>>)	이 AsyncPipeline에 작업 컬렉션을 추가합니다.
Wait()	현재 큐에 대기 중인 모든 비동기 작업이 완료될 때까지 기다립니다. 호출 스레드를 차단합니다.