zoukankan      html  css  js  c++  java
  • 标准的并发控制实现

                public void ScheduleIncomingRequest(IEndpointIncomingRequest request)
                {
                    // queue the request.
                    lock (m_lock)   // i.e. Monitor.Enter(m_lock)
                    {
                        // check able to schedule requests.
                        if (m_stopped || m_queue.Count >= m_maxRequestCount)
                        {
                            request.OperationCompleted(null, StatusCodes.BadTooManyOperations);
                            return;
                        }
    
                        m_queue.Enqueue(request);
    
                        // wake up an idle thread to handle the request if there is one
                        if (m_activeThreadCount < m_totalThreadCount)
                        {
                            Monitor.Pulse(m_lock);
                        }
                        // start a new thread to handle the request if none are idle and the pool is not full.
                        else if (m_totalThreadCount < m_maxThreadCount)
                        {
                            Thread thread = new Thread(OnProcessRequestQueue);
                            thread.IsBackground = true;
                            thread.Start(null);
                            m_totalThreadCount++;
                            m_activeThreadCount++;  // new threads start in an active state
    
                            Utils.Trace("Thread created: " + Thread.CurrentThread.ManagedThreadId + ". Current thread count: " + m_totalThreadCount + ". Active thread count" + m_activeThreadCount);
                        }
                    }
                }
                /// <summary>
                /// Processes the requests in the request queue.
                /// </summary>
                private void OnProcessRequestQueue(object state)
                {
                    lock (m_lock)   // i.e. Monitor.Enter(m_lock)
                    {
                        while (true)
                        {
                            // check if the queue is empty.
                            while (m_queue.Count == 0)
                            {
                                m_activeThreadCount--;
    
                                // wait for a request. end the thread if no activity.
                                if (m_stopped || (!Monitor.Wait(m_lock, 30000) && m_totalThreadCount > m_minThreadCount))
                                {
                                    m_totalThreadCount--;
    
                                    Utils.Trace("Thread ended: " + Thread.CurrentThread.ManagedThreadId + ". Current thread count: " + m_totalThreadCount + ". Active thread count" + m_activeThreadCount);
    
                                    return;
                                }
    
                                m_activeThreadCount++;
                            }
    
                            IEndpointIncomingRequest request = m_queue.Dequeue();
    
                            Monitor.Exit(m_lock);
    
                            try
                            {
                                // process the request.
                                m_server.ProcessRequest(request, state);
                            }
                            catch (Exception e)
                            {
                                Utils.Trace(e, "Unexpected error processing incoming request.");
                            }
                            finally
                            {
                                Monitor.Enter(m_lock);
                            }
                        }
                    }
                }
  • 相关阅读:
    序列合并(luogu 1631)题解
    邮递员送信(luogu 1629)题解
    敲砖块(codevs 1257)题解
    货车运输(codevs 3287)题解
    分布式服务框架 Zookeeper -- 管理分布式环境中的数据
    dubbo学习
    第一章 1.20 多线程基础
    第一章 1.19 网络编程基础
    练习 : 面向对象
    练习 : 正则表达式
  • 原文地址:https://www.cnblogs.com/yayaxxww/p/5228741.html
Copyright © 2011-2022 走看看