6

我正在尝试创建一个与第三方 API 的连接池,如果连接未在使用中,则会在一段时间后过期。当它们过期时,需要通过第三方 API 断开它们。

看来 MemoryCache (System.Runtime.Caching) 会处理这个问题。不过,UpdateCallback 的行为似乎很奇怪。

一个简单的 LINQPad 示例:

void Main()
{
    var cache = MemoryCache.Default;
    var policy = new CacheItemPolicy();
    policy.AbsoluteExpiration = DateTimeOffset.Now.AddSeconds(1);
    policy.UpdateCallback = Update;
    cache.Set("figkey", "fig", policy);

    Thread.Sleep(2000);

    object result = cache.Get("figkey");

    Console.WriteLine(result == null ? "null" : result);
}

public static void Update(CacheEntryUpdateArguments arguments)
{
    Console.WriteLine("got here");
}

如果我运行它,输出是:

fig

它不输出“到这里”。

如果我注释掉以 开头的行policy.UpdateCallback,则输出为:

null

我究竟做错了什么?

如果有更好的方法来完成我的任务,我愿意接受其他建议。

4

3 回答 3

4

我认为问题可能是Thread.Sleep因为这也阻塞了缓存,因为它们在同一个线程中运行。如果您尝试制作虚拟循环,您将触发更新处理程序:

var i = 0;
for (var j = 0; j < 10000000; j++)
{
    for (var k = 0; k < 1000000; k++)
        i++;
    i--;
}
Console.WriteLine(i);

而不是睡觉。

于 2012-03-10T22:27:54.217 回答
1

只需在 Main 末尾添加 Console.ReadLine() 或将 Sleep 替换为 Console.ReadLine(),启动示例并等待大约 10 秒。您将收到预期的消息。MemoryCache 里面的定时器有点慢。

但无论如何,MemoryCache 中肯定存在一个错误:分配 UpdateCallback 会改变行为,但它不应该。

如果设置了 AbsoluteExpiration 并且时间已过,则 Get 方法必须返回 null,而不依赖于 UpdateCallback 的存在。

顺便说一句, RemovedCallback 不会改变行为。

于 2012-12-27T14:19:32.590 回答
0

只需将睡眠时间增加到更大的时间,您就会看到回调被执行。

过期确实通过计时器在另一个线程上发生(如果您在回调中设置断点,您可以看到同样多)。这就是为什么睡眠或忙碌等待都有效的原因。

于 2014-02-24T23:55:49.623 回答