111

MemoryCacheクラスを使用してキャッシュを作成しました。いくつかのアイテムを追加しますが、キャッシュをリロードする必要がある場合は、最初にキャッシュをクリアしたいと思います。これを行う最も簡単な方法は何ですか?すべてのアイテムをループして一度に1つずつ削除する必要がありますか、それともより良い方法がありますか?

4

11 に答える 11

69

Dispose既存のMemoryCacheを作成し、新しいMemoryCacheオブジェクトを作成します。

于 2010-11-15T10:12:45.577 に答える
60

列挙の問題

MemoryCache.GetEnumerator()の備考セクションでは、次のように警告しています。「MemoryCacheインスタンスの列挙子の取得は、リソースを大量に消費し、ブロックする操作です。したがって、列挙子を本番アプリケーションで使用しないでください。」

GetEnumerator()実装の擬似コードで説明されている理由は次のとおりです。

Create a new Dictionary object (let's call it AllCache)
For Each per-processor segment in the cache (one Dictionary object per processor)
{
    Lock the segment/Dictionary (using lock construct)
    Iterate through the segment/Dictionary and add each name/value pair one-by-one
       to the AllCache Dictionary (using references to the original MemoryCacheKey
       and MemoryCacheEntry objects)
}
Create and return an enumerator on the AllCache Dictionary

実装はキャッシュを複数のDictionaryオブジェクトに分割するため、列挙子を返すには、すべてを1つのコレクションにまとめる必要があります。GetEnumeratorを呼び出すたびに、上記の完全なコピープロセスが実行されます。新しく作成されたディクショナリには、元の内部キーおよび値オブジェクトへの参照が含まれているため、実際にキャッシュされたデータ値は複製されません。

ドキュメントの警告は正しいです。GetEnumerator()を避けてください-LINQクエリを使用する上記のすべての回答を含みます。

より優れた、より柔軟なソリューション

これは、既存の変更監視インフラストラクチャに基づいて構築されたキャッシュをクリアする効率的な方法です。また、キャッシュ全体または名前付きサブセットのみをクリアする柔軟性を提供し、上記の問題はありません。

// By Thomas F. Abraham (http://www.tfabraham.com)
namespace CacheTest
{
    using System;
    using System.Diagnostics;
    using System.Globalization;
    using System.Runtime.Caching;

    public class SignaledChangeEventArgs : EventArgs
    {
        public string Name { get; private set; }
        public SignaledChangeEventArgs(string name = null) { this.Name = name; }
    }

    /// <summary>
    /// Cache change monitor that allows an app to fire a change notification
    /// to all associated cache items.
    /// </summary>
    public class SignaledChangeMonitor : ChangeMonitor
    {
        // Shared across all SignaledChangeMonitors in the AppDomain
        private static event EventHandler<SignaledChangeEventArgs> Signaled;

        private string _name;
        private string _uniqueId = Guid.NewGuid().ToString("N", CultureInfo.InvariantCulture);

        public override string UniqueId
        {
            get { return _uniqueId; }
        }

        public SignaledChangeMonitor(string name = null)
        {
            _name = name;
            // Register instance with the shared event
            SignaledChangeMonitor.Signaled += OnSignalRaised;
            base.InitializationComplete();
        }

        public static void Signal(string name = null)
        {
            if (Signaled != null)
            {
                // Raise shared event to notify all subscribers
                Signaled(null, new SignaledChangeEventArgs(name));
            }
        }

        protected override void Dispose(bool disposing)
        {
            SignaledChangeMonitor.Signaled -= OnSignalRaised;
        }

        private void OnSignalRaised(object sender, SignaledChangeEventArgs e)
        {
            if (string.IsNullOrWhiteSpace(e.Name) || string.Compare(e.Name, _name, true) == 0)
            {
                Debug.WriteLine(
                    _uniqueId + " notifying cache of change.", "SignaledChangeMonitor");
                // Cache objects are obligated to remove entry upon change notification.
                base.OnChanged(null);
            }
        }
    }

    public static class CacheTester
    {
        public static void TestCache()
        {
            MemoryCache cache = MemoryCache.Default;

            // Add data to cache
            for (int idx = 0; idx < 50; idx++)
            {
                cache.Add("Key" + idx.ToString(), "Value" + idx.ToString(), GetPolicy(idx));
            }

            // Flush cached items associated with "NamedData" change monitors
            SignaledChangeMonitor.Signal("NamedData");

            // Flush all cached items
            SignaledChangeMonitor.Signal();
        }

        private static CacheItemPolicy GetPolicy(int idx)
        {
            string name = (idx % 2 == 0) ? null : "NamedData";

            CacheItemPolicy cip = new CacheItemPolicy();
            cip.AbsoluteExpiration = System.DateTimeOffset.UtcNow.AddHours(1);
            cip.ChangeMonitors.Add(new SignaledChangeMonitor(name));
            return cip;
        }
    }
}
于 2014-03-13T19:26:49.840 に答える
37

http://connect.microsoft.com/VisualStudio/feedback/details/723620/memorycache-class-needs-a-clear-methodから

回避策は次のとおりです。

List<string> cacheKeys = MemoryCache.Default.Select(kvp => kvp.Key).ToList();
foreach (string cacheKey in cacheKeys)
{
    MemoryCache.Default.Remove(cacheKey);
}
于 2012-02-29T14:00:12.280 に答える
24
var cacheItems = cache.ToList();

foreach (KeyValuePair<String, Object> a in cacheItems)
{
    cache.Remove(a.Key);
}
于 2011-09-07T12:45:10.527 に答える
12

パフォーマンスが問題にならない場合は、この素敵なワンライナーでうまくいきます。

cache.ToList().ForEach(a => cache.Remove(a.Key));
于 2013-12-29T01:35:24.047 に答える
9

トリム方式があるようです。

したがって、すべてのコンテンツをクリアするには、

cache.Trim(100)

編集: もう少し掘り下げた後、トリムを調べることはあなたの時間の価値がないようです

https://connect.microsoft.com/VisualStudio/feedback/details/831755/memorycache-trim-method-doesnt-evict-100-of-the-items

System.Runtime.Caching.MemoryCacheをクリアするにはどうすればよいですか

于 2014-04-11T09:12:11.383 に答える
4

これに出くわし、それに基づいて、もう少し効果的な並列クリアメソッドを作成しました。

    public void ClearAll()
    {
        var allKeys = _cache.Select(o => o.Key);
        Parallel.ForEach(allKeys, key => _cache.Remove(key));
    }
于 2014-07-18T05:42:36.960 に答える
3

次のようなこともできます。


Dim _Qry = (From n In CacheObject.AsParallel()
           Select n).ToList()
For Each i In _Qry
    CacheObject.Remove(i.Key)
Next
于 2011-07-13T14:06:59.323 に答える
1

MemoryCache.Defaultキャッシュを破棄してから、プライベートフィールドのシングルトンをnullにリセットして、MemoryCache.Defaultを再作成することができます。

       var field = typeof(MemoryCache).GetField("s_defaultCache",
            BindingFlags.Static |
            BindingFlags.NonPublic);
        field.SetValue(null, null);
于 2020-07-16T09:54:31.257 に答える
1

私はキャッシュをクリアすることにのみ興味があり、c#GlobalCachingProviderを使用するときにこれをオプションとして見つけました

                var cache = GlobalCachingProvider.Instance.GetAllItems();
                if (dbOperation.SuccessLoadingAllCacheToDB(cache))
                {
                    cache.Clear();
                }
于 2020-07-24T12:58:47.283 に答える
0

マグリットの答えの少し改善されたバージョン。

var cacheKeys = MemoryCache.Default.Where(kvp.Value is MyType).Select(kvp => kvp.Key).ToList();
foreach (string cacheKey in cacheKeys)
{
    MemoryCache.Default.Remove(cacheKey);
}
于 2013-10-30T20:08:32.663 に答える