AsyncAwait

비동기

이 라이브러리 (Delphi 10 이상)는 com 인프라 ( icontextCallback.contextCallback )를 사용하여 메인 또는 임의의 스레드에서 계속 통화를 동기화하는 .NET의 작업 및 작업 <T> 객체의 느슨한 등가물을 노출시킵니다. 동일한 API는 C# 및 VC ++의 CO_AWAIT 에서 Async/Await 에 의해 사용됩니다. 라이브러리는 EXE 및 DLL 프로젝트에서 작동하며 ( TTHREAD.SYNCHORNIZE 와 달리) 주기적으로 통화를 확인 하여 확인하지 않습니다.

소스 코드는 MIT 라이센스에 따라 라이센스가 부여됩니다.

이 라이브러리를 사용하려면 ASYNCAWAIT를 사용 조항에 추가하십시오. 그런 다음 다음과 같은 코드를 만들 수 있습니다.

 procedure TForm1.btnFibonacciClick (Sender: TObject);
var
  seed: UInt64;
begin
  seed := Random(MaxInt);
  lblResult.Caption := Format( ' Calculating Fibonacci number for %d. Please wait... ' , [seed]);
  TTask<UInt64>.Async(
              // timeconsuming call on a secondary thread
              function : UInt64
              begin
                Result := Fibonacci(seed);
              end ,
              // update the UI on the main thread
              procedure(task : ITask<UInt64>; Value : UInt64)
              begin
                if task.Status = TTaskStatus.RanToCompletion
                  then lblResult.Caption := Format( ' Fibonacci number for %d is %d ' , [seed, Value ])
                else if task.Status = TTaskStatus.Faulted
                  then lblResult.Caption := Format( ' Error calculating Fibonacci number: %s ' , [task.Exception.Message])
              end ,
              // tell to continue on the main thread -
              // don't need to specify this parameter as it defaults to true anyway
              true
              );
end ;

보조 스레드에서 새 작업을 시작하더라도 특정 동기화 컨텍스트를 지정할 수도 있습니다.

 procedure TForm1.Button1Click (Sender: TObject);
var
  t : ITask<integer>;
  syncContext : ISynchronizationContext;
begin
  syncContext := TSynchronizationContext.Current;

  t := TTask<integer>.Async(

              // async function
              function() : integer
              var
                delay : integer;
              begin
                delay := Random( 10000 );
                sleep(delay);
                Result := delay;
                // run another task
                // start it explicitly since we need to configure the
                // synchornization context (main thread) first
                // before the continuation code has a chance to run
                TTask.Create(
                     procedure()
                     begin
                       sleep( 2000 );
                     end
                   ).
                   ContinueWith(
                     procedure(task : ITask)
                     begin
                       ShowMessage( ' Done second task ' );
                     end ,
                     // use the sync context from the main thread since we are showing a window
                     syncContext
                     ).
                   // now start the task after we configured it
                   Start;
              end ,

              // continue with
              // it is guaranteed to run on the calling thread (this main thread)
              // since continueOnCapturedContext parameter defaults to true
              procedure(task : ITask<integer>; Value : integer )
              begin
                if task.Status = TTaskStatus.RanToCompletion
                  then ShowMessage(Format( ' All done after sleeping for %d seconds ' , [task. Value div 1000 ]))
                else if task.Status = TTaskStatus.Faulted
                  then ShowMessage(Format( ' Task faulted. Exception type = %s: %s ' , [task.Exception.ClassName, task.Exception.Message]))
              end ,
              // continue on the main thread - don't need to specify this parameter as it defaults to true
              true
                );
  if t.Wait( 2000 )
    then ShowMessage(Format( ' Done after waiting for less than 2 seconds. Task returned %d ' , [t. Value ]))
    else ShowMessage( ' Still not done after waiting for 2 seconds ' );
end ;