zoukankan      html  css  js  c++  java
  • 多线程同步

    private System.Threading.ReaderWriterLock rwl;
            public DataBase()
            {
                rwl = new System.Threading.ReaderWriterLock();
            }
            /// <summary>
            /// 该方法Command执行ExecuteReader操作
            /// </summary>
            public IDataReader ExecSqlReader(string sqlText, List<IDbDataParameter> parameterList = null)
            {
                rwl.AcquireWriterLock(System.Threading.Timeout.Infinite);
                IDataReader drReader;
                SqlConnection(sqlText, false);
                AddParameter(parameterList);
                IDBConnection.Open();
                drReader = IDBCommand.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
                rwl.ReleaseWriterLock();
                return drReader;
            }
    private static object objLock = new object();
            /// <summary>
            /// 该方法Command执行ExecuteReader操作
            /// </summary>
            public IDataReader ExecSqlReader(string sqlText, List<IDbDataParameter> parameterList = null)
            {
                lock (objLock)
                {
                    IDataReader drReader;
                    SqlConnection(sqlText, false);
                    AddParameter(parameterList);
                    IDBConnection.Open();
                    drReader = IDBCommand.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
    
                    return drReader;
                }
            }
    static int i = 0;
            /// <summary>
            /// 该方法Command执行ExecuteReader操作
            /// </summary>
            public IDataReader ExecSqlReader(string sqlText, List<IDbDataParameter> parameterList = null)
            {
                IDataReader drReader = null;
                while (true)
                {
                    if (i == 0)
                    {
                        System.Threading.Interlocked.Increment(ref  i);
                        SqlConnection(sqlText, false);
                        AddParameter(parameterList);
                        IDBConnection.Open();
                        drReader = IDBCommand.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
                        System.Threading.Interlocked.Decrement(ref  i);
                        break;
                    }
                }
                return drReader;
            }
  • 相关阅读:
    重启停止的作业 bg和fg
    shell nohup 让脚本一直以后台模式运行到结束
    shell jobs查看作业
    shell 移除信号捕获
    shell 多进程运行程序
    shell 脚本后台运行
    python3 生产者消费者
    python3 生产者消费者(守护线程)
    python3 进程线程协程 并发查找列表
    python3 线程间通信
  • 原文地址:https://www.cnblogs.com/daixingqing/p/4437271.html
Copyright © 2011-2022 走看看