автоматически истекают Service Fabric Надежный словарь объектов с помощью RunAsync

Question

Я пытаюсь добавить автоматизированные делеции в истекших надежный словарь объектов и, похоже, я должен реализовать свой собственный путь в соответствии с этим: 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())); 
       } 
      } 
     } 
    } 
} 

Ошибка: ошибка происходит на «в то время (правда)» после того, как я добавил несколько надежных словаря объектов в моем словаре.

Помощник по удаленной обработке «FatalExecutionEngineError» обнаружил проблему в «C: \ SfDevCluster \ Data_App_Node_2 \ CacheApplicationType_App339 \ CachePkg.Code.1.0.0 \ Cache.exe».

Дополнительная информация: Время выполнения столкнулось с фатальной ошибкой. Адрес ошибки был равен 0x8c46ed90, на потоке 0x1980. Код ошибки: 0x80131623. Эта ошибка может быть ошибкой в ​​CLR или в небезопасных или не поддающихся проверке частях кода пользователя. Общие источники этой ошибки включают ошибки маршалинга пользователя для COM-interop или PInvoke, которые могут повредить стек.

Answer 1

Если надежный словарь содержит более одного элемента, готового к истечению срока действия, вышеуказанный код продолжает использовать транзакцию после ее прекращения (совершенного в вышеуказанном случае). Это вызывает утверждение в перечислении, поскольку оно используется после того, как транзакция, с которой она была связана, прекратилась.

Я буду обновлять эту рекомендацию в Reliable Collections к

• Не следует использовать перечисление после операции, используемой для создания прекращается (совершено/прерванный) или утилизированы.