VSoft.Awaitable

Vsoft.Awaitable

Dies ist eine einfache Bibliothek, um asynchrone Funktionsaufrufe zu tätigen. Es ist ein Wrapper über Omnithreadlibrary und basiert auf seiner eigenen parallel.aSync -Funktionalität.

Parallel.async bietet keine einfache Möglichkeit, Anrufe zu stornieren und über die Stornierung informiert zu werden, und erlaubt nicht die Rückgabe der Ergebnisse.

Verwendung

Fügen Sie vsoft.Awaitable in Ihre Verwendungsklausel ein.

    TAsync.Configure<string>(
        function ( const cancelToken : ICancellationToken) : string
        var
          i: Integer;
        begin
            result := ' Hello ' + value ;
            for i := 0 to 2000 do
            begin
              Sleep( 1 );
              // in loops, check the token
              if cancelToken.IsCancelled then
                exit;
            end ;

            // where api's can take a handle for cancellation, use the token.handle
            WaitForSingleObject(cancelToken.Handle, 5000 );

            // any unhandled exceptions here will result in the on exception proc being called (if configured)
            // raise Exception.Create('Error Message');
        end , token);
    )
    .OnException(
        procedure ( const e : Exception)
        begin
          Label1.Caption := e.Message;
        end )
    .OnCancellation(
        procedure
        begin
            // clean up
            Label1.Caption := ' Cancelled ' ;
        end )
    .Await(
        procedure ( const value : string)
        begin
            // use result
            Label1.Caption := value ;
        end );

Sie können auch IAwaitable<TResult> aus Funktionen zurückgeben

 function LoadAsyncWithToken ( const token : ICancellationToken; const value : string) : IAwaitable<string>;
begin
  // configure our async call and return the IAwaitable<string>
  result := TAsync.Configure<string>(
        function( const cancelToken : ICancellationToken) : string
        begin
            // .... do some long running thing
            result := ' Hello ' + value ;
        end , token);
end ;

// for when there is no result to return
function RunIt ( const token : ICancellationToken; const value : string) : IAwaitable;
begin
  // configure our async call and return the IAwaitable<string>
  result := TAsync.Configure(
        procedure( const cancelToken : ICancellationToken)
        begin
        // .... do some long running thing
        end , token);
end ;


procedure UseIt ;
begin
     LoadAsyncWithToken( ' param ' , FTokenSource.Token)
     .OnException(
        procedure ( const e : Exception)
        begin
          Label1.Caption := e.Message;
        end )
    .OnCancellation(
        procedure
        begin
            // clean up
            Label1.Caption := ' Cancelled ' ;
        end )
    .Await(
        procedure ( const value : string)
        begin
            // use result
            Label1.Caption := value ;
        end );

     RunIt( ' param ' , FTokenSource.Token)
     .OnException(
        procedure ( const e : Exception)
        begin
          Label1.Caption := e.Message;
        end )
    .OnCancellation(
        procedure
        begin
            // clean up
            Label1.Caption := ' Cancelled ' ;
        end )
    .Await(
        procedure
        begin
            // use result
            Label1.Caption := ' Done ' ;
        end );

Beachten Sie, dass auf die asynchronisierte Funktion tatsächlich erwartet wird. Es gibt auch eine Überlastung von tasync.configure, die keinen Stornierungs -Token für die Absage von Stornierung annimmt.