加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 百科 > 正文

c# – 使用超时模式锁定

发布时间:2020-12-15 08:15:58 所属栏目:百科 来源:网络整理
导读:lock使用这种模式 if(Monitor.Enter(lock)) try { ... } finally { Monitor.Exit(lock); } // using this style to reduce post "height" 如果我们不想等待无限,我们可以提供超时 if(!Monitor.TryEnter(lock,timeout)) throw new TimeoutException();try{ ..
lock使用这种模式
if(Monitor.Enter(lock))
    try
    {
        ...
    }
    finally { Monitor.Exit(lock); } // using this style to reduce post "height"

如果我们不想等待无限,我们可以提供超时

if(!Monitor.TryEnter(lock,timeout))
    throw new TimeoutException();
try
{
    ...
}
finally { Monitor.Exit(lock); }

我有方法,方法必须在开始做任何事情之前获得多个锁.这看起来很糟糕:

if(!Monitor.TryEnter(lockA,timeout))
    throw new TimeoutException();
try
{
    if(!Monitor.TryEnter(lockB,timeout))
        throw new TimeoutException();
    try
    {
        if(!Monitor.TryEnter(lockC,timeout))
            throw new TimeoutException();
        try
        {
            ... // more of such constructions
        }
        finally { Monitor.Exit(lockC); }
    }
    finally { Monitor.Exit(lockB); }
}
finally { Monitor.Exit(lockA); }

它有问题:

>看起来很难看(方法代码是缩进的,想象它将如何查找lockZ),可以通过将方法代码放入另一个方法来解决.
>锁定同步发生,因此最糟糕的成功案例可能需要的时间略小于所有超时的总和.

有没有办法改善这种超时模式?

我正在考虑使用delegate参数创建一个方法并使用lock来实现类似linq chaining的东西(但是也要并行运行锁,这是一个挑战):

Lock(lockA).Lock(lockB).Lock(lockC).Run( () => ...);

或许还有另一种方式?

解决方法

我会使用同步锁:
using System;
using System.Threading; 

public class MyLock : IDisposable
{
    private object lockObj;

    public Lock(object lockObj,TimeSpan timeout)
    {
        this.lockObj = lockObj;
        if (!Monitor.TryEnter(this.lockObj,timeout))
            throw new TimeoutException();
    }

    public void Dispose()
    {
        Monitor.Exit(lockObj);
    }
}

用法:

using(new MyLock(lockA,new TimeSpan.FromSeconds(1)))
using(new MyLock(lockB,new TimeSpan.FromSeconds(2)))
using(new MyLock(lockC,new TimeSpan.FromSeconds(3)))
{
    // your code
}

不知道在ctor中“锁定”是否是好的模式/设计,但它会起作用;)

对于异步.分区化并不是一个好主意.为什么?如果某个线程将进入监视器,则同一个线程必须离开它(带锁定退出).因此,如果您在Parallel.ForEach(f.e.)中锁定objA,您将不知道哪个线程已经完成了它.所以你将无法发布它.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读