AsyncExecutorWithRetries.ExecuteWithRetries Methode

Definition

Namespace:

Orleans.Internal

Assembly:

Orleans.Core.dll

Paket:

Microsoft.Orleans.Core v8.2.0

Überlädt

ExecuteWithRetries(Func<Int32,Task>, Int32, Func<Exception,Int32,Boolean>, TimeSpan, IBackoffProvider)	Führen Sie eine bestimmte Funktion basierend auf Wiederholungskonfigurationsparametern mehrmals aus.
ExecuteWithRetries<T>(Func<Int32,Task<T>>, Int32, Func<Exception,Int32,Boolean>, TimeSpan, IBackoffProvider)	Führen Sie eine bestimmte Funktion basierend auf Wiederholungskonfigurationsparametern mehrmals aus.
ExecuteWithRetries<T>(Func<Int32,Task<T>>, Int32, Int32, Func<T, Int32,Boolean>, Func<Exception,Int32,Boolean>, TimeSpan, IBackoffProvider, IBackoffProvider)	Führen Sie eine bestimmte function Anzahl von Malen basierend auf Wiederholungskonfigurationsparametern aus.

ExecuteWithRetries(Func<Int32,Task>, Int32, Func<Exception,Int32,Boolean>, TimeSpan, IBackoffProvider)

Führen Sie eine bestimmte Funktion basierend auf Wiederholungskonfigurationsparametern mehrmals aus.

public static System.Threading.Tasks.Task ExecuteWithRetries (Func<int,System.Threading.Tasks.Task> action, int maxNumErrorTries, Func<Exception,int,bool> retryExceptionFilter, TimeSpan maxExecutionTime, Orleans.Internal.IBackoffProvider onErrorBackOff);

static member ExecuteWithRetries : Func<int, System.Threading.Tasks.Task> * int * Func<Exception, int, bool> * TimeSpan * Orleans.Internal.IBackoffProvider -> System.Threading.Tasks.Task

Public Shared Function ExecuteWithRetries (action As Func(Of Integer, Task), maxNumErrorTries As Integer, retryExceptionFilter As Func(Of Exception, Integer, Boolean), maxExecutionTime As TimeSpan, onErrorBackOff As IBackoffProvider) As Task

Parameter

action

Func<Int32,Task>

Die auszuführende Aktion.

maxNumErrorTries

Int32

Die maximale Anzahl von Warnungen.

retryExceptionFilter

Func<Exception,Int32,Boolean>

Der Wiederholungs-Ausnahmefilter.

maxExecutionTime

TimeSpan

Die maximale Ausführungsdauer.

onErrorBackOff

IBackoffProvider

Der Backoffanbieter.

Gibt zurück

Task

Ein Task , der den Vorgang darstellt.

ExecuteWithRetries<T>(Func<Int32,Task<T>>, Int32, Func<Exception,Int32,Boolean>, TimeSpan, IBackoffProvider)

Führen Sie eine bestimmte Funktion basierend auf Wiederholungskonfigurationsparametern mehrmals aus.

public static System.Threading.Tasks.Task<T> ExecuteWithRetries<T> (Func<int,System.Threading.Tasks.Task<T>> function, int maxNumErrorTries, Func<Exception,int,bool> retryExceptionFilter, TimeSpan maxExecutionTime, Orleans.Internal.IBackoffProvider onErrorBackOff);

static member ExecuteWithRetries : Func<int, System.Threading.Tasks.Task<'T>> * int * Func<Exception, int, bool> * TimeSpan * Orleans.Internal.IBackoffProvider -> System.Threading.Tasks.Task<'T>

Public Shared Function ExecuteWithRetries(Of T) (function As Func(Of Integer, Task(Of T)), maxNumErrorTries As Integer, retryExceptionFilter As Func(Of Exception, Integer, Boolean), maxExecutionTime As TimeSpan, onErrorBackOff As IBackoffProvider) As Task(Of T)

Typparameter

T

Parameter

function

Func<Int32,Task<T>>

Der auszuführende Delegat.

maxNumErrorTries

Int32

Die maximale Anzahl von Warnungen.

retryExceptionFilter

Func<Exception,Int32,Boolean>

Der Wiederholungs-Ausnahmefilter.

maxExecutionTime

TimeSpan

Die maximale Ausführungsdauer.

onErrorBackOff

IBackoffProvider

Der Backoffanbieter.

Gibt zurück

Task<T>

Der Wert, der vom erfolgreichen Aufruf der bereitgestellten Funktion zurückgegeben wird.

ExecuteWithRetries<T>(Func<Int32,Task<T>>, Int32, Int32, Func<T, Int32,Boolean>, Func<Exception,Int32,Boolean>, TimeSpan, IBackoffProvider, IBackoffProvider)

Führen Sie eine bestimmte function Anzahl von Malen basierend auf Wiederholungskonfigurationsparametern aus.

public static System.Threading.Tasks.Task<T> ExecuteWithRetries<T> (Func<int,System.Threading.Tasks.Task<T>> function, int maxNumSuccessTries, int maxNumErrorTries, Func<T,int,bool> retryValueFilter, Func<Exception,int,bool> retryExceptionFilter, TimeSpan maxExecutionTime = default, Orleans.Internal.IBackoffProvider onSuccessBackOff = default, Orleans.Internal.IBackoffProvider onErrorBackOff = default);

static member ExecuteWithRetries : Func<int, System.Threading.Tasks.Task<'T>> * int * int * Func<'T, int, bool> * Func<Exception, int, bool> * TimeSpan * Orleans.Internal.IBackoffProvider * Orleans.Internal.IBackoffProvider -> System.Threading.Tasks.Task<'T>

Public Shared Function ExecuteWithRetries(Of T) (function As Func(Of Integer, Task(Of T)), maxNumSuccessTries As Integer, maxNumErrorTries As Integer, retryValueFilter As Func(Of T, Integer, Boolean), retryExceptionFilter As Func(Of Exception, Integer, Boolean), Optional maxExecutionTime As TimeSpan = Nothing, Optional onSuccessBackOff As IBackoffProvider = Nothing, Optional onErrorBackOff As IBackoffProvider = Nothing) As Task(Of T)

Typparameter

T

Der zugrunde liegende Rückgabetyp von function.

Parameter

function

Func<Int32,Task<T>>

Auszuführende Funktion

maxNumSuccessTries

Int32

Maximale Anzahl erfolgreicher Ausführungsversuche. ExecuteWithRetries(Func<Int32,Task>, Int32, Func<Exception,Int32,Boolean>, TimeSpan, IBackoffProvider) versucht, die angegebene function erneut auszuführen, wenn dies von angewiesen wird retryValueFilter . Legen Sie für eine unbegrenzte Anzahl erfolgreicher Wiederholungen auf fest -1 , bis retryValueFilter der Vorgang erfüllt ist. Legen Sie für nur einen erfolgreichen Versuch auf 0 fest, was dazu führt retryValueFilter , dass ignoriert und der angegebene function nur einmal ausgeführt wird, bis der erste Erfolg erfolgreich ist.

maxNumErrorTries

Int32

Maximale Anzahl von Ausführungsversuchen aufgrund von Fehlern. Legen Sie für eine unbegrenzte Anzahl von Fehlerversuchen auf -1 fest, bis retryExceptionFilter dies erfüllt ist.

retryValueFilter

Func<T,Int32,Boolean>

Filter function , um anzugeben, ob eine erfolgreiche Ausführung wiederholt werden soll. Legen Sie auf fest null , um erfolgreiche Wiederholungsversuche zu deaktivieren.

retryExceptionFilter

Func<Exception,Int32,Boolean>

Filter function , um anzugeben, ob die Fehlerausführung wiederholt werden soll. Legen Sie auf fest null , um Fehlerversuche zu deaktivieren.

maxExecutionTime

TimeSpan

Die maximale Ausführungszeit der ExecuteWithRetries(Func<Int32,Task>, Int32, Func<Exception,Int32,Boolean>, TimeSpan, IBackoffProvider) Funktion.

onSuccessBackOff

IBackoffProvider

Das Backoffanbieterobjekt, das bestimmt, wie viel zwischen erfolgreichen Wiederholungsversuchen gewartet werden soll.

onErrorBackOff

IBackoffProvider

Das Backoff-Anbieterobjekt, das bestimmt, wie viel zwischen Fehlerversuchen gewartet werden soll.

Gibt zurück

Task<T>

Der Wert, der vom erfolgreichen Aufruf von functionzurückgegeben wird.