async/await을 직렬화하는 방법은 무엇입니까?

Question

의 난이 간단한 조각이 있다고 가정하자

는

async void button_Click(object sender, RoutedEventArgs e) 
{ 
    await Task.Factory.StartNew(() => 
    { 
     Console.WriteLine("start"); 
     Thread.Sleep(5000); 
     Console.WriteLine("end"); 
    }); 
} 

은 물론, 매번 나는 이전 작업이 여전히 실행하면 새 작업도 시작 버튼 있음을 누릅니다. 이전 작업이 모두 끝날 때까지 새로운 작업을 연기하려면 어떻게합니까?

좀 더 자세한 사항 : 위의 예에서

은, 각각의 새로운 작업은 이전 작업과 동일합니다. 그러나 원래 컨텍스트에서는 작업 순서가 중요합니다. 매개 변수가 변경 될 수 있습니다 (DateTime.Now.Ticks을 사용하여 "시뮬레이션"할 수 있음). 작업은 "등록"된 순서대로 실행해야합니다. 구체적으로 말하자면, 내 프로그램은 시리얼 장치와 통신 할 것이다. 전에 BlockingCollection을 사용하는 백그라운드 스레드로이 작업을 수행했습니다. 그러나 이번에는 엄격한 요청/응답 프로토콜이 있으며 가능한 경우 async/await를 사용하고 싶습니다.

가능한 해결 방법 : 나는 작업을 생성하고 목록에 저장 상상할 수

. 그러나 요구 사항과 관련된 작업을 어떻게 수행 할 수 있습니까? 또는 이전에 사용한 스레드 기반 솔루션으로 돌아 가야합니까?

Answer 1

SemaphoreSlim을 비동기 적으로 기다렸다가 작업이 완료되면 놓을 수 있습니다. 세마포어 초기 값을 1으로 설정하는 것을 잊지 마십시오.

private static SemaphoreSlim semaphore = new SemaphoreSlim(1); 

private async static void DoSomethingAsync() 
{ 
    await semaphore.WaitAsync(); 
    try 
    { 
     await Task.Factory.StartNew(() => 
     { 
      Console.WriteLine("start"); 
      Thread.Sleep(5000); 
      Console.WriteLine("end"); 
     }); 
    } 
    finally 
    { 
     semaphore.Release(); 
    } 
} 

private static void Main(string[] args) 
{ 
    DoSomethingAsync(); 
    DoSomethingAsync(); 
    Console.Read(); 
} 

Answer 2

동기화를 위해 SemaphoreSlim을 사용하는 것이 좋습니다. 그러나 avoid Task.Factory.StartNew (블로그에서 설명 함) 및 definitely avoid async void (MSDN 기사에서 설명 함)을 원합니다.

private SemaphoreSlim _mutex = new SemaphoreSlim(1); 
async void button_Click(object sender, RoutedEventArgs e) 
{ 
    await Task.Run(async() => 
    { 
    await _mutex.WaitAsync(); 
    try 
    { 
     Console.WriteLine("start"); 
     Thread.Sleep(5000); 
     Console.WriteLine("end"); 
    } 
    finally 
    { 
     _mutex.Release(); 
    } 
    }); 
} 

Answer 3

뭔가 누락되었을 수 있지만 OP의 시나리오에는 SemaphoreSlim이 필요하지 않습니다. 나는 그것을 다음과 같이 할 것이다. 기본적으로, 코드 단지 await (선명도에 대한 예외 처리를) 계속하지 전에 작업의 이전 보류 예 :

// the current pending task (initially a completed stub) 
Task _pendingTask = Task.FromResult<bool>(true); 

async void button_Click(object sender, RoutedEventArgs e) 
{ 
    var previousTask = _pendingTask; 

    _pendingTask = Task.Run(async() => 
    { 
     await previousTask; 

     Console.WriteLine("start"); 
     Thread.Sleep(5000); 
     Console.WriteLine("end"); 
    }); 

    // the following "await" is optional, 
    // you only need it if you have other things to do 
    // inside "button_Click" when "_pendingTask" is completed 
    await _pendingTask; 
} 

[업데이트] 코멘트를 해결하기 위해, 여기 스레드 안전 버전은, 때 button_Click는 할 수 있어요 동시에 호출 :

Task _pendingTask = Task.FromResult<bool>(true); 
object _pendingTaskLock = new Object(); 

async void button_Click(object sender, RoutedEventArgs e) 
{ 
    Task thisTask; 

    lock (_pendingTaskLock) 
    { 
     var previousTask = _pendingTask; 

     // note the "Task.Run" lambda doesn't stay in the lock 
     thisTask = Task.Run(async() => 
     { 
      await previousTask; 

      Console.WriteLine("start"); 
      Thread.Sleep(5000); 
      Console.WriteLine("end"); 
     }); 

     _pendingTask = thisTask; 
    } 

    await thisTask; 
} 

Answer 4

무엇 (기본값)과 1의 최대 병렬 처리 수준은 우려를 잠금/스레드 안전의에 대해 걱정할 필요가 없습니다이 방법을 Dataflow.ActionBlock<T> 시도에 대해. 또한 설치가 ActionBlock는이 Task 또는 Func<Task>, 단순히 실행 /이 입력을 기다리고받을 수

... 
var _block = new ActionBlock<bool>(async b => 
       { 
        Console.WriteLine("start"); 
        await Task.Delay(5000); 
        Console.WriteLine("end"); 
       }); 
... 


async void button_Click(object sender, RoutedEventArgs e) 
{ 
    await _block.SendAsync(true); 
} 

:

이 같은 것을 볼 수 있었다. 여러 작업을 대기열에두고 다른 소스에서 기다릴 수 있습니다.