zoukankan      html  css  js  c++  java
  • Hashtable的锁sample

    要实现lock hashtable有两种方式:

    1.锁SyncRoot:
    第一步:申明同步HashTable-->Hashtable.Synchronized(new Hashtable());
    第二步:第一次访问的时候,lock SyncRoot-->lock (this.table.SyncRoot)
    当有其他线程访问这个被lock住的HashTable时,需要等待,直到lock释放.看一下示例代码:
     

    SyncRoot
    public class HashTableLockSyncRoot
    {
    private Hashtable table;

    public HashTableLockSyncRoot()
    {
    this.table = Hashtable.Synchronized(new Hashtable());
    table.Add(
    "K", "0");
    }


    public void ExecuteSample()
    {
    Thread T1
    = new Thread(SynT1);
    Thread T2
    = new Thread(SynT2);

    T1.Start();
    T2.Start();

    Thread.Sleep(
    5000);
    Console.WriteLine(
    "-----Main method-----");
    Console.WriteLine(
    this.table["K"].ToString());

    }

    private void SynT1()
    {
    lock (this.table.SyncRoot)
    {
    Thread.Sleep(
    3000);

    Console.WriteLine(
    "-----Thread 1 before write-----");
    Console.WriteLine(
    this.table["K"].ToString());

    this.table["K"] = "1";

    Console.WriteLine(
    "-----Thread 1 after write-----");
    Console.WriteLine(
    this.table["K"].ToString());
    }


    }

    private void SynT2()
    {

    Console.WriteLine(
    "-----Thread 2 before write-----");
    Console.WriteLine(
    this.table["K"].ToString());

    this.table["K"] = "2";

    Console.WriteLine(
    "-----Thread 2 after write-----");
    Console.WriteLine(
    this.table["K"].ToString());

    }

    }

    2.锁实例
    如果你要采用锁实例的方式,那么和上面的区别时,你在每次要访问HashTable的时候,都需要lock HashTable实例。代码如下:

    Lock instance
    public class HashTableLockInstance
    {
    private Hashtable table;

    public HashTableLockInstance()
    {
    this.table = new Hashtable();
    this.table.Add("K", "V0");
    }


    public void ExecuteSample()
    {
    Thread T1
    = new Thread(SynT1);
    Thread T2
    = new Thread(SynT2);

    T1.Start();
    T2.Start();

    Thread.Sleep(
    5000);

    Console.WriteLine(
    "----Main method-----");
    Console.WriteLine(
    this.table["K"].ToString());

    }

    private void SynT1()
    {
    lock (this.table.SyncRoot)
    {
    Thread.Sleep(
    3000);

    Console.WriteLine(
    "-----Thread 1 before write-----");
    Console.WriteLine(
    this.table["K"].ToString());


    table[
    "K"] = "V1";

    Console.WriteLine(
    "-----Thread 1 after write-----");
    Console.WriteLine(
    this.table["K"].ToString());
    }
    }

    private void SynT2()
    {
    lock (this.table.SyncRoot)
    {
    Console.WriteLine(
    "-----Thread 2 before write-----");
    Console.WriteLine(
    this.table["K"].ToString());

    table[
    "K"] = "V2";

    Console.WriteLine(
    "-----Thread 2 after write-----");
    Console.WriteLine(
    this.table["K"].ToString());
    }
    }
    }

     
    3.两者的区别:
    SynRoot: 允许多个线程同时读,只允许一个线程写;而Lock instance则只允许一个线程同时读写。

    补充:

    (1). public virtual Object SyncRoot { get; }

    To create a synchronized version of the ArrayList, use the Synchronized method. However, derived classes can provide their own synchronized version of the ArrayList using the SyncRoot property. The synchronizing code must perform operations on the SyncRoot of the ArrayList, not directly on the ArrayList. This ensures proper operation of collections that are derived from other objects. Specifically, it maintains proper synchronization with other threads that might be simultaneously modifying the ArrayList object. (也就是说只是阻止同步的修改,允许同步的读取)

    ==============================================================================================================
    (2). public static ArrayList Synchronized(
     ArrayList list
    )
    To guarantee the thread safety of the ArrayList, all operations must be done through this wrapper(只允许一个线程读取).

    ==============================================================================================================
    (3). Enumerating through a collection is intrinsically not a thread-safe procedure (枚举读取ArrayList是线程不安全的). Even when a collection is synchronized, other threads can still modify the collection, which causes the enumerator to throw an exception. To guarantee thread safety during enumeration, you can either lock the collection during the entire enumeration or catch the exceptions resulting from changes made by other threads.
    安全的读取方式:

    ArrayList myCollection = new ArrayList();
    lock(myCollection.SyncRoot) {
    foreach (Object item in myCollection) {
    // Insert your code here.
    }
    }

     

  • 相关阅读:
    Linux——k8s命令别名修改
    k8s—centos7安装部署NFS服务器和客户端及基于nfs的动态存储storageclass使用总结
    MySQL—用户和权限管控
    MySQL—常用SQL语句整理总结
    Zookeeper——入门介绍(相关原理、安装启动及使用操作)
    SpringBoot——Quartz定时框架的使用详解和总结
    SpringBoot——@Scheduled的自定义周期性线程池解决任务延时执行问题
    Linux—用户新建目录和文件的默认权限设置:umask详解
    设计模式——单例模式详解
    Linux—CPU核数、上下文切换介绍及pidstat等命令详解
  • 原文地址:https://www.cnblogs.com/yang_sy/p/1632887.html
Copyright © 2011-2022 走看看