Talkative Locker 模式

简介:

原文地址:http://www.codeproject.com/KB/architecture/TalkativeLockerPattern.aspx

我想要开发一个简单的设计模式,可以使开发人员更容易调试多线程的程序。在这篇文章中,我将介绍TalkativeLocker设计模式。TalkativeLocker模式的目的是将锁定的代码与其他的代码隔离开,只有单一点锁可以进入,获得,释放。下面是简单演示:

public class TalkativeLocker<T>
{
    private readonly static object toLock = new object();

    public T EnterLock(IClient client, Func<T> function)
    {
        T result = default(T);
        Console.WriteLine(client.Name + ":Waiting for lock");

        Monitor.Enter(toLock);

        try
        {
            Console.WriteLine(client.Name + ":AquiredLock");
            result = function();
        }
        catch (Exception ex)
        {
            //
        }
        finally
        {
            Console.WriteLine(client.Name + ":About release lock");
            Monitor.Exit(toLock);
        }
        return result;
    }
}

TalkativeLocker 包括一个私有的对象toLock用于锁定。该对象是Static的,这就是说他是共享的,一次只有一个线程可以在他上面获得锁。TalkativeLocker 还有一个Func<T>参数表示当获得锁的时候调用的程序。

下面看看如何使用TalkativeLocker 类,先定义接口如下:

public interface IClient
{
    string Name
    {
        get;
        set;
    }
}

}

该接口只有一个Name属性,该属性可以让开发人员在调试多线程程序时更方便的显示相关调试信息。下面是该类的简单实现:

public class Client : IClient
{
    private string name = String.Empty;
    private readonly TalkativeLocker<int> talkativeLocker = new TalkativeLocker<int>();

    public Client(string name)
    {
        Name = name;
    }

    public string Name
    {
        get
        {
            return name;
        }
        set
        {
            name = value;
        }
    }

    public int AddTwoNumbers()
    {
        return 1 + 2;
    }

    public void DoSomething()
    {
        int result = talkativeLocker.EnterLock(this, AddTwoNumbers);
    }
}

主程序如下:

static void Main(string[] args)
{
    Client[] clients = new Client[10];

    clients[0] = new Client("1");
    clients[1] = new Client("2");
    clients[2] = new Client("3");
    clients[3] = new Client("4");
    clients[4] = new Client("5");
    clients[5] = new Client("6");
    clients[6] = new Client("7");
    clients[7] = new Client("8");
    clients[8] = new Client("9");
    clients[9] = new Client("10");

    foreach (Client client in clients)
    {
        Thread t = new Thread(client.DoSomething);
        t.Start();
    }

    Thread.CurrentThread.Join();
    Console.ReadLine();
}

运行结果如下:

TalkativeThreadLocker

 


本文转自生鱼片博客园博客,原文链接:http://www.cnblogs.com/carysun/archive/2009/11/26/TalkativeLocker.html,如需转载请自行联系原作者

相关文章
|
7月前
|
消息中间件 存储 网络性能优化
|
8月前
|
设计模式 运维 安全
边车模式的介绍
边车模式的介绍
109 0
|
8月前
一般模式
【2月更文挑战第20天】一般模式。
59 1
|
8月前
|
设计模式 算法 编译器
【C/C++ PIMPL模式 】 深入探索C++中的PIMPL模式
【C/C++ PIMPL模式 】 深入探索C++中的PIMPL模式
342 0
|
分布式计算 自然语言处理 并行计算
运用Aggregator模式实现MapReduc
运用Aggregator模式实现MapReduc
运用Aggregator模式实现MapReduc
|
前端开发 JavaScript Java
MVX模式是什么?
MVX模式是什么?
301 0
使用不完整的模式
使用不完整的模式
87 0
|
设计模式 PHP
php设计模式-注册器模式
php设计模式-注册器模式
150 0
|
C语言
模式
模式
147 0