欧美性猛交XXXX免费看蜜桃,成人网18免费韩国,亚洲国产成人精品区综合,欧美日韩一区二区三区高清不卡,亚洲综合一区二区精品久久

using System;using System.Threading;namespace ThreadPoolApplication{    class Program    {        //設定任務(wù)數量         static int count = 5;        static void Main(string[] args)        {            //關(guān)于ManualResetEvent大伙不必深究，后續章將會(huì )詳細闡述，這里由于假設            //讓線(xiàn)程池執行5個(gè)任務(wù)所以也為每個(gè)任務(wù)加上這個(gè)對象保持同步            ManualResetEvent[] events=new ManualResetEvent[count];            Console.WriteLine("當前主線(xiàn)程id:{0}",Thread.CurrentThread.ManagedThreadId);            //循環(huán)每個(gè)任務(wù)            for (int i = 0; i < count; i++)            {                //實(shí)例化同步工具                events[i]=new ManualResetEvent(false);                //Test在這里就是任務(wù)類(lèi)，將同步工具的引用傳入能保證共享區內每次只有一個(gè)線(xiàn)程進(jìn)入                Test tst = new Test(events[i]);                Thread.Sleep(1000);                //將任務(wù)放入線(xiàn)程池中，讓線(xiàn)程池中的線(xiàn)程執行該任務(wù)
                ThreadPool.QueueUserWorkItem(tst.DisplayNumber, new { num1=2});            }            //注意這里，設定WaitAll是為了阻塞調用線(xiàn)程（主線(xiàn)程），讓其余線(xiàn)程先執行完畢，            //其中每個(gè)任務(wù)完成后調用其set()方法(收到信號),當所有            //的任務(wù)都收到信號后，執行完畢，將控制權再次交回調用線(xiàn)程（這里的主線(xiàn)程）            ManualResetEvent.WaitAll(events);                       Console.ReadKey();        }    }    public class Test     {        ManualResetEvent manualEvent;        public Test(ManualResetEvent manualEvent)         {            this.manualEvent = manualEvent;        }        public void DisplayNumber(object a)         {            Console.WriteLine("當前運算結果:{0}",((dynamic)a).num1);            Console.WriteLine("當前子線(xiàn)程id:{0} 的狀態(tài):{1}", Thread.CurrentThread.ManagedThreadId,Thread.CurrentThread.ThreadState);            //這里是方法執行時(shí)間的模擬，如果注釋該行代碼，就能看出線(xiàn)程池的功能了            //Thread.Sleep(30000);            //這里是釋放共享鎖，讓其他線(xiàn)程進(jìn)入            manualEvent.Set();        }    }}

        //定義一個(gè)委托        public delegate void DoSomething();        static void Main(string[] args)        {            //1.實(shí)例化一個(gè)委托，調用者發(fā)送一個(gè)請求，請求執行該方法體（還未執行）            DoSomething doSomething = new DoSomething(                () =>                 {                     Console.WriteLine("如果委托使用beginInvoke的話(huà)，這里便是異步方法體");                    //4，實(shí)現完這個(gè)方法體后自動(dòng)觸發(fā)下面的回調函數方法體                });            //3 。調用者（主線(xiàn)程）去觸發(fā)異步調用，采用異步的方式請求上面的方法體           IAsyncResult result= doSomething.BeginInvoke(                //2.自定義上面方法體執行后的回調函數                new AsyncCallback                    (                    //5.以下是回調函數方法體                     //asyncResult.AsyncState其實(shí)就是AsyncCallback委托中的第二個(gè)參數                       asyncResult => {                           doSomething.EndInvoke(asyncResult);                           Console.WriteLine(asyncResult.AsyncState.ToString());                        }                    )                , "BeginInvoke方法的第二個(gè)參數就是傳入AsyncCallback中的AsyncResult.AsyncState,我們使用時(shí)可以強轉成相關(guān)類(lèi)型加以使用");            //DoSomething......調用者（主線(xiàn)程）會(huì )去做自己的事情            Console.ReadKey();        }

    /// <summary>        /// .net 4.5 中 async 和 await 全新的關(guān)鍵字 一起實(shí)現異步的簡(jiǎn)化        /// </summary>        void async ShowUriContent(string uri)        {            using (FileStream fs = File.OpenRead("你的文件地址"))            {                using (FileStream fs2 = new FileStream())                {                    byte[] buffer = new byte[4096];                    //FileStream的ReadAsync方法也是net4.5版本出現的，它返回一個(gè)Task<int>對象                    //而且作用于await后的異步代碼會(huì )等待阻塞直到異步方法完成后返回                    int fileBytesLength = await fs.ReadAsync(buffer,0,buffer.Length).ConfigureAwait(false);                    while(fileBytesLength>0)                    {                           //FileStream的WriteAsync方法也是net4.5版本出現的                           await fs2.WriteAsync(buffer,0,buffer.Length).ConfigureAwait(false);                          }                             }            }        }

        static void Main(string[] args)        {            ThreadStart[] startArray =            {              new ThreadStart(()=>{                  Console.WriteLine("第一個(gè)任務(wù)");               }),              new ThreadStart(()=>{Console.WriteLine("第二個(gè)任務(wù)");}),              new ThreadStart(()=>{Console.WriteLine("第三個(gè)任務(wù)");}),              new ThreadStart(()=>{Console.WriteLine("第四個(gè)任務(wù)");}),            };
            MyThreadPool.SetMaxWorkThreadCount(2);
            MyThreadPool.MyQueueUserWorkItem(startArray);            Console.ReadKey();        }       /// <summary>       /// 自定義一個(gè)簡(jiǎn)單的線(xiàn)程池，該線(xiàn)程池實(shí)現了默認開(kāi)啟線(xiàn)程數       /// 當最大線(xiàn)程數全部在繁忙時(shí)，循環(huán)等待，只到至少一個(gè)線(xiàn)程空閑為止       /// 本示例使用BackgroundWorker模擬后臺線(xiàn)程，任務(wù)將自動(dòng)進(jìn)入隊列和離開(kāi)       /// 隊列       /// </summary>        sealed class MyThreadPool        {            //線(xiàn)程鎖對象            private static object lockObj = new object();            //任務(wù)隊列            private static Queue<ThreadStart> threadStartQueue = new Queue<ThreadStart>();            //記錄當前工作的任務(wù)集合，從中可以判斷當前工作線(xiàn)程使用數，如果使用int判斷的話(huà)可能會(huì )有問(wèn)題，            //用集合的話(huà)還能取得對象的引用，比較好            private static HashSet<ThreadStart> threadsWorker = new HashSet<ThreadStart>();            //當前允許最大工作線(xiàn)程數            private static int maxThreadWorkerCount = 1;            //當前允許最小工作線(xiàn)程數            private static int minThreadWorkerCount = 0;            /// <summary>            /// 設定最大工作線(xiàn)程數            /// </summary>            /// <param name="maxThreadCount">數量</param>            public static void SetMaxWorkThreadCount(int maxThreadCount)             {                maxThreadWorkerCount =minThreadWorkerCount>maxThreadCount?                minThreadWorkerCount : maxThreadCount;            }            /// <summary>            /// 設定最小工作線(xiàn)程數            /// </summary>            /// <param name="maxThreadCount">數量</param>            public static void SetMinWorkThreadCount(int minThreadCount)            {                minThreadWorkerCount = minThreadCount > maxThreadWorkerCount ?                maxThreadWorkerCount : minThreadCount;            }            /// <summary>            /// 啟動(dòng)線(xiàn)程池工作            /// </summary>            /// <param name="threadStartArray">任務(wù)數組</param>            public static void MyQueueUserWorkItem(ThreadStart[] threadStartArray)            {                //將任務(wù)集合都放入到線(xiàn)程池中                AddAllThreadsToPool(threadStartArray);                //線(xiàn)程池執行任務(wù)                ExcuteTask();            }            /// <summary>            /// 將單一任務(wù)加入隊列中            /// </summary>            /// <param name="ts">單一任務(wù)對象</param>            private static void AddThreadToQueue(ThreadStart ts)            {                lock (lockObj)                {                    threadStartQueue.Enqueue(ts);                }            }            /// <summary>            /// 將多個(gè)任務(wù)加入到線(xiàn)程池的任務(wù)隊列中            /// </summary>            /// <param name="threadStartArray">多個(gè)任務(wù)</param>            private static void AddAllThreadsToPool(ThreadStart[] threadStartArray)            {                foreach (var threadStart in threadStartArray)                    AddThreadToQueue(threadStart);            }            /// <summary>            /// 執行任務(wù)，判斷隊列中的任務(wù)數量是否大于0，如果是則判斷當前正在使用的工作線(xiàn)程的            /// 數量是否大于等于允許的最大工作線(xiàn)程數，如果一旦有線(xiàn)程空閑的話(huà)            /// 就會(huì )執行ExcuteTaskInQueen方法處理任務(wù)            /// </summary>            private static void ExcuteTask()            {                while (threadStartQueue.Count > 0)                {                    if (threadsWorker.Count < maxThreadWorkerCount)                    {                        ExcuteTaskInQueen();                    }                }            }            /// <summary>            /// 執行出對列的任務(wù)，加鎖保護            /// </summary>            private static void ExcuteTaskInQueen()            {                lock (lockObj)                {                    ExcuteTaskByThread(threadStartQueue.Dequeue());                }            }            /// <summary>            /// 實(shí)現細節，這里使用BackGroudWork來(lái)實(shí)現后臺線(xiàn)程            /// 注冊doWork和Completed事件，當執行一個(gè)任務(wù)前，前將任務(wù)加入到            /// 工作任務(wù)集合（表示工作線(xiàn)程少了一個(gè)空閑），一旦RunWorkerCompleted事件被觸發(fā)則將任務(wù)從工作            /// 任務(wù)集合中移除（表示工作線(xiàn)程也空閑了一個(gè)）            /// </summary>            /// <param name="threadStart"></param>            private static void ExcuteTaskByThread(ThreadStart threadStart)            {                threadsWorker.Add(threadStart);                BackgroundWorker worker = new BackgroundWorker();                worker.DoWork += (o, e) => { threadStart.Invoke(); };                worker.RunWorkerCompleted += (o, e) => { threadsWorker.Remove(threadStart); };                worker.RunWorkerAsync();            }        }

    /// <summary>    /// 異步IHttpHandler,實(shí)現了一個(gè)簡(jiǎn)單的統計流量的功能，    /// 由于是示例代碼，所以沒(méi)有判斷IP或者M(jìn)AC    /// </summary>    public class Handler1 : IHttpAsyncHandler    {        //默認訪(fǎng)問(wèn)量是0        static int visitCount = 0;        /// <summary>        /// 這個(gè)HttpHandler的同步方法        /// </summary>        /// <param name="context"></param>        public void ProcessRequest(HttpContext context)        {        }        public bool IsReusable        {            get            {                return false;            }        }        /// <summary>        /// 實(shí)現IHttpAsyncHandler 接口方法        /// </summary>        /// <param name="context">當前HttpContext</param>        /// <param name="cb">回調函數</param>        /// <param name="extraData"></param>        /// <returns></returns>        public IAsyncResult BeginProcessRequest(HttpContext context, AsyncCallback cb, object extraData)        {            //這里可以加上判斷IP或mac的方法            visitCount++;            //實(shí)例化AsyncUserVisiteCounterResult對象            AsyncUserVisiteCounterResult result = new AsyncUserVisiteCounterResult(cb, visitCount, context);            result.Display();            return result;        }       /// <summary>        ///  結束本次IHttpAsyncHandler工作時(shí)觸發(fā)的request方法       /// </summary>       /// <param name="result"></param>        public void EndProcessRequest(IAsyncResult result)        {                  }    }    /// <summary>    /// 自定義IAsyncResult 實(shí)現我們額外的Display方法    /// </summary>    public class AsyncUserVisiteCounterResult : IAsyncResult    {        //回調參數        private object _param;        //是否異步執行完成        private bool _asyncIsComplete;        //回調方法        private AsyncCallback _callBack;        //當前上下文        private HttpContext _context;        public AsyncUserVisiteCounterResult(AsyncCallback callBack, object stateParam, HttpContext context)        {            this._callBack = callBack;            this._param = stateParam;            _asyncIsComplete = false;            this._context = context;        }        public object AsyncState        {            get { return this._param; }        }        /// <summary>        /// 等待句柄用于同步功能，關(guān)于等待句柄會(huì )在后續章節陳述/// </summary>        public System.Threading.WaitHandle AsyncWaitHandle        {            get            {                return null;            }        }        /// <summary>        /// 該屬性表示不需要異步任務(wù)同步完成        /// </summary>        public bool CompletedSynchronously        {            get { return false; }        }        /// <summary>        /// 該屬性表示異步任務(wù)是否已經(jīng)執行完成        /// </summary>        public bool IsCompleted        {            get            {                return this._asyncIsComplete;            }        }        /// <summary>        /// 自定義的額外功能,需要注意的是，執行完異步功能后        /// 要將_asyncIsComplete設置為true表示任務(wù)執行完畢而且        /// 執行回調方法，否則異步工作無(wú)法結束頁(yè)面會(huì )卡死        /// </summary>        public void Display()        {            //這里先不用waitHandle句柄來(lái)實(shí)現同步            lock (this)            {                this._context.Response.Write("你是第" + (int)this._param + "位訪(fǎng)問(wèn)者，訪(fǎng)問(wèn)時(shí)間:"+DateTime.Now.ToString());                this._asyncIsComplete = true;                this._callBack(this);            }        }    }

    <httpHandlers>
      <add verb="*" path="AsyncThreadInAsp.net.Handler1.ashx" type="AsyncThreadInAsp.net.Handler1"/>
    </httpHandlers>