스레드 콜백을 대기하는 방법은 무엇입니까?

Question

async을 사용하지 않고 기존 스레드와 콜백을 사용하는 멀티 스레드 라이브러리를 사용하고 있습니다.

그래서 같이 async 함수에서이 코드를 호출 오전 을

var connection = new SomeLib(); 
connection.OnConnected += (x) => { /* This is called from separate thread */ } 
connection.Connect(); 

을 을 :

public async Task<Boolean> MyFunc() 
{ 
    var connection = new SomeLib(); 
    connection.OnConnected += (x) => { /* This is called from separate thread */ } 
    connection.Connect(); 

    // ... 

    // Need to return after OnConnected has been fired. 
    return true; 
} 

가 어떻게이 OnConnected 콜백은 "대기"내 기능을 가지고 await를 사용하여 호출 될?

Answer 1

다음은 EventHandler <> 유형 이벤트에서 작동하지만 다른 서명 위임자에서 작동하도록 쉽게 조정할 수 있습니다. 먼저 도우미 함수 (EventToATaskAsync)가 ch는 덧셈기를 제거하고 이벤트를 설정/해제하는 대리인을 제거합니다.

이 메커니즘을 사용하는 단점은 래핑 된 비동기 작업마다 확장 메서드를 작성해야한다는 것입니다.

public static Task<A> EventToTaskAsync<A>(Action<EventHandler<A>> adder, Action<EventHandler<A>> remover) 
{ 
    System.Threading.Tasks.TaskCompletionSource<A> tcs = new TaskCompletionSource<A>(); 
    EventHandler<A> onComplete = null; 
    onComplete = (s, e) => 
    { 
     remover(onComplete); 
     tcs.SetResult(e); 
    }; 
    adder(onComplete); 
    return tcs.Task; 
} 

그런 다음 일반적으로 기존 클래스에 작업 기능을 추가하기 위해 확장 호출을 사용하여 포장합니다. 다음 예제에서, 나는 (하지만 이벤트 메커니즘을 사용하여 거의 아무것도 그렇게 할 수) 스토리 보드에 BeginAsync를 추가하고 : 도움이

public static Task BeginAsync(this Storyboard storyboard) 
    { 
     return EventToTaskAsync<object>(
       e => { storyboard.Completed += e; storyboard.Begin(); }, 
       e => storyboard.Completed -= e); 
    } 

희망을.

Answer 2

대기 핸들을 사용하여이 작업을 수행 할 수 있습니다. 트리거 핸들 대기, 연결 호출하는 기능에

waitForConnect.Set(); 

: 트리거, 핸들을 OnConnected 핸들러에서

private waitForConnect = new AutoResetEvent(false); 

: 먼저 AutoResetEvent를 정의

connection.Connect(); 
waitForConnect.WaitOne(); // This will sleep the thread until connected