AsyncAwait

AsyncaWait

Perpustakaan ini (Delphi 10 atau lebih tinggi) memaparkan kesetaraan yang longgar dari tugas dan tugas <T> objek di .net yang menggunakan infrastruktur COM ( icontextCallback.contextCallback ) untuk menyinkronkan panggilan kelanjutan pada utas utama atau sewenang -wenang. API yang sama digunakan oleh Async/Await di C# dan Co_AWAIT di VC ++. Perpustakaan bekerja dalam proyek EXE dan DLL dan (tidak seperti tThread.synchornize ) tidak bergantung pada panggilan berkala untuk checksynchronize .

Kode sumber dilisensikan di bawah lisensi MIT.

Untuk menggunakan perpustakaan ini, tambahkan AsyncaWait ke klausa Penggunaan; Anda kemudian dapat membuat kode seperti yang berikut:

 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 ;

Anda juga dapat menentukan konteks sinkronisasi tertentu bahkan jika Anda memulai tugas baru pada utas sekunder:

 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 ;