[C#] C # 5 비동기 CTP : EndAwait 호출 전에 생성 된 코드에서 내부“상태”가 0으로 설정된 이유는 무엇입니까?

좋아, 나는 마침내 진정한 대답을 얻었다. 나는 그것을 스스로 해결했지만 팀의 VB 부분에서 Lucian Wischik이 실제로 그럴만한 이유가 있음을 확인한 후에야 해결되었습니다. 그에게 많은 감사를 전합니다- 그의 블로그 를 방문하십시오 .

여기서 값 0은 특별하기 때문에 특별합니다. 하지 방금 전에 할 수있는 유효한 상태 await보통의 경우. 특히, 상태 머신이 다른 곳에서 테스트를 마칠 수있는 상태가 아닙니다. 내가 아닌 양의 값을 사용하는 것이 단지 잘 작동 믿습니다 : 그것은으로 -1이 사용되지 않습니다 논리적으로 일반적으로 “완료”를 의미로 -1, 잘못된. 현재 상태 0에 추가 의미를 부여한다고 주장 할 수는 있지만 실제로는 중요하지 않습니다. 이 질문의 요점은 왜 국가가 전혀 설정되지 않았는지 알아내는 것이 었습니다.

발견 된 예외에서 대기가 종료되면 값이 관련됩니다. 우리는 같은 await 문으로 다시 돌아올 수 있지만, “모든 대기에서 돌아 오려고한다”는 상태 가 아니어야합니다. 그렇지 않으면 모든 종류의 코드가 건너 뜁니다. 이것을 예제와 함께 보여주는 것이 가장 간단합니다. 이제 두 번째 CTP를 사용하고 있으므로 생성 된 코드는 질문의 코드와 약간 다릅니다.

비동기 방법은 다음과 같습니다.

static async Task<int> FooAsync()
{
    var t = new SimpleAwaitable();

    for (int i = 0; i < 3; i++)
    {
        try
        {
            Console.WriteLine("In Try");
            return await t;
        }
        catch (Exception)
        {
            Console.WriteLine("Trying again...");
        }
    }
    return 0;
}

개념적으로, 그 SimpleAwaitable작업은 기다릴 수 있습니다. 어쩌면 작업이거나 다른 것일 수 있습니다. 테스트 목적으로 항상 false를 반환합니다.IsCompleted 하고에 예외를 발생 GetResult시킵니다.

생성 된 코드는 다음과 같습니다 MoveNext.

public void MoveNext()
{
    int returnValue;
    try
    {
        int num3 = state;
        if (num3 == 1)
        {
            goto Label_ContinuationPoint;
        }
        if (state == -1)
        {
            return;
        }
        t = new SimpleAwaitable();
        i = 0;
      Label_ContinuationPoint:
        while (i < 3)
        {
            // Label_ContinuationPoint: should be here
            try
            {
                num3 = state;
                if (num3 != 1)
                {
                    Console.WriteLine("In Try");
                    awaiter = t.GetAwaiter();
                    if (!awaiter.IsCompleted)
                    {
                        state = 1;
                        awaiter.OnCompleted(MoveNextDelegate);
                        return;
                    }
                }
                else
                {
                    state = 0;
                }
                int result = awaiter.GetResult();
                awaiter = null;
                returnValue = result;
                goto Label_ReturnStatement;
            }
            catch (Exception)
            {
                Console.WriteLine("Trying again...");
            }
            i++;
        }
        returnValue = 0;
    }
    catch (Exception exception)
    {
        state = -1;
        Builder.SetException(exception);
        return;
    }
  Label_ReturnStatement:
    state = -1;
    Builder.SetResult(returnValue);
}

나는 움직여야했다 Label_ContinuationPoint유효한 코드 해야했습니다. 그렇지 않으면 goto명령문 의 범위에 속하지 않지만 답변에 영향을 미치지 않습니다.

GetResult예외가 발생하면 어떻게되는지 생각해보십시오 . 우리는 catch 블록을 거쳐 증가 i하고 다시 순환합니다 ( i아직도 3보다 작다고 가정합니다 ). 우리는 우리가 전에 있었다 어떤 상태에 아직도 GetResult전화 …하지만 우리는 안에 얻을 때 try블록 우리는 해야한다 “시도에서”인쇄하고 전화를 GetAwaiter다시 … 우리는 할 수 있습니다 상태 1.없이이 아닌 경우 그 state = 0할당, 그것은 기존의 awaiter을 사용하고 건너 뜁니다Console.WriteLine 전화를.

작업하기에는 상당히 고의적 인 코드이지만 팀이 생각해야 할 종류를 보여줍니다. 나는 이것을 구현할 책임이 없다는 것이 기쁘다. 🙂

답변

this.<a1>t__$await2 = this.t1.GetAwaiter<int>();
this.<>1__state = 1;
this.$__doFinallyBodies = false;
this.<a1>t__$await2.BeginAwait(this.MoveNextDelegate)
this.<>1__state = 0;

//second thread
this.<a1>t__$await2 = this.t1.GetAwaiter<int>();
this.<>1__state = 1;
this.$__doFinallyBodies = false;
this.<a1>t__$await2.BeginAwait(this.MoveNextDelegate)
this.$__doFinallyBodies = true;
this.<>1__state = 0;
this.<1>t__$await1 = this.<a1>t__$await2.EndAwait();

//other thread
this.<1>t__$await1 = this.<a1>t__$await2.EndAwait();

//second thread
//I suppose this un matched call to EndAwait will fail
this.<1>t__$await1 = this.<a1>t__$await2.EndAwait();

async Task m1()
{
    await m2;
}

async Task m2()
{
    await m3();
}

async Task m3()
{
Thread.Sleep(10000);
}