AsyncAwait
1.0.0
このライブラリ(Delphi 10以降)は、Com Infrastructure( icontextCallback.ContextCallback )を使用する.NETのタスクとタスク<T>オブジェクトのゆるい同等物を公開し、メインまたは任意のスレッドでの継続コールを同期させます。同じAPIは、VC ++のC#およびCO_AWAITでASYNC/待機で使用されます。ライブラリは、exeプロジェクトとDLLプロジェクトの両方で機能し、( tthread.synchornizeとは異なり) CheckSynchronizeの定期的な呼び出しに依存していません。
ソースコードは、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 ;