Я пытаюсь добавить автоматические удаления к надежным объектам словаря с истекшим сроком действия, и похоже, что мне нужно реализовать свой собственный способ в соответствии с этим: https://stackoverflow.com/a/36466890/7293543
Мой подход заключался в том, чтобы использовать задачу «RunAsync» и постоянно запускать цикл while. Первые несколько раз это сработало, но я получаю странную ошибку, когда добавляю еще несколько объектов в свой словарь. Это глупый подход? Как другие люди автоматически очищают свои надежные словарные объекты?
protected override async Task RunAsync(CancellationToken cancellationToken)
{
while (true)
{
cancellationToken.ThrowIfCancellationRequested();
await deleteExpired("MyDictionaryName", cancellationToken);
}
}
private async Task deleteExpired(string dictionaryName, CancellationToken cancellationToken)
{
var myDictionary = await this.StateManager.GetOrAddAsync<IReliableDictionary<string, CacheObject>>(dictionaryName);
Dictionary<string, CacheObject> ret = new Dictionary<string, CacheObject>();
using (var tx = StateManager.CreateTransaction())
{
var count = myDictionary.GetCountAsync(tx);
if (count.Result > 0)
{
IAsyncEnumerator<KeyValuePair<string, CacheObject>> e = (await myDictionary.CreateEnumerableAsync(tx)).GetAsyncEnumerator();
while (await e.MoveNextAsync(cancellationToken))
{
if (e.Current.Value.expiration <= DateTime.Now)
{
await myDictionary.TryRemoveAsync(tx, e.Current.Key);
await tx.CommitAsync();
ServiceEventSource.Current.ServiceMessage(this.Context, String.Format("Object deleted at {0} - key: {1} expired at {2}", DateTime.Now.ToString(), e.Current.Key, e.Current.Value.expiration.ToString()));
}
}
}
}
}
Ошибка: ошибка возникает на «while (true)» после того, как я добавил в свой словарь несколько надежных словарных объектов.
Помощник по управляемой отладке «FatalExecutionEngineError» обнаружил проблему в «C: \ SfDevCluster \ Data_App_Node_2 \ CacheApplicationType_App339 \ CachePkg.Code.1.0.0 \ Cache.exe».
Дополнительная информация: среда выполнения обнаружила фатальную ошибку. Адрес ошибки был 0x8c46ed90 в потоке 0x1980. Код ошибки - 0x80131623. Эта ошибка может быть ошибкой в CLR или в небезопасных или неподдающихся проверке частях пользовательского кода. Общие источники этой ошибки включают ошибки маршалинга пользователей для COM-взаимодействия или PInvoke, которые могут повредить стек.
while (true)
в вашем коде, и откуда вы знаете, что ошибка возникает вwhile (true)
, когда это очевидно фатальная ошибка в вашем процессе, а не исключение .NET с трассировкой стека, которая позволяет вам понять, какая часть вашего код, который не удался? Я не думаю, что в вашем коде есть что-то, что может вызвать подобную ошибку, поэтому я предполагаю, что ошибка не связана с опубликованным вами кодом или вы столкнулись с ошибкой в Service Fabric. - person Martin Liversage   schedule 29.12.2016CommitAsync
должен быть после внутреннего цикла while (вы не можете использовать транзакцию после фиксации). 2. Добавьте задержкуawait Task.Delay(...)
послеawait deleteExpired..
. 3. Не рекомендуется совмещать операции одного и нескольких объектов в одной транзакции. - person Aleksey L.   schedule 29.12.2016