多線程編程學習筆記——線程池（三）

来源:http://www.cnblogs.com/chillsrc/archive/2017/11/20/7864929.html
-Advertisement-
Play Games

本示例主要學習如果對線程池中的操作實現超時，併在線程池中正確等待。 線程池還有一個ThreadPool.RegisterWaitForSingleObject，這個方法允許我們將回調函數放入線程池中的隊列中。當提供的等待事件處理器接收到信號或發生超時時，這個回調函數將被調用，這樣就實現了... ...


接上文 多線程編程學習筆記——線程池（一）

接上文 多線程編程學習筆記——線程池（二）

 

五、     線上程池中使用等待事件處理器與超時

     本示例主要學習如果對線程池中的操作實現超時，併在線程池中正確等待。

     線程池還有一個ThreadPool.RegisterWaitForSingleObject，這個方法允許我們將回調函數放入線程池中的隊列中。當提供的等待事件處理器接收到信號或發生超時時，這個回調函數將被調用，這樣就實現了為線程池中操作實現超時操作。

1.代碼如下：

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;
namespace ThreadTPLDemo
{

    class Program
    {   

        static void Main(string[] args)
        {
            Console.WriteLine("開始測試線程池中定時運行操作。。。");
            TimesOperation(TimeSpan.FromSeconds(5));//提供了5秒的操作時間，會超時
            TimesOperation(TimeSpan.FromSeconds(9));//提供了9秒的操作時間，正常工作
            Console.WriteLine("。。。。。。。。。。。。。。。。");
            Console.Read();
        }

        private static void  TimesOperation(TimeSpan  workTimes)
        {
            using (var manuEvt=new ManualResetEvent(false))
            {
                using (var cts=new CancellationTokenSource())
                {
                    Console.WriteLine("開始--線程池中的定時操作。。。");
                    var work = ThreadPool.RegisterWaitForSingleObject
                        (manuEvt, (state, isTimeOut) => AsyncOperWait(cts, isTimeOut), null, workTimes, true);
                    Console.WriteLine("一個長時間運行的線程操作。。。");

                    ThreadPool.QueueUserWorkItem(_ => AsyncOper(cts.Token, manuEvt));
                    Console.WriteLine("。。。間隔2秒再次運行。。。");                    Thread.Sleep(workTimes.Add(TimeSpan.FromSeconds(2)));
                    work.Unregister(manuEvt);
                }
            } 
        }
        private static void AsyncOper(CancellationToken token,ManualResetEvent mrevt)
        {
            Console.WriteLine("開始--線程池中的第一個工作線程。。。");
            for (int i = 0; i < 7; i++)
            {
                if (token.IsCancellationRequested)//判斷是否已經取消操作
                {
                    Console.WriteLine("使用輪詢方法取消工作線程  ID：{0}", Thread.CurrentThread.ManagedThreadId);
                    return;
                }
                Thread.Sleep(TimeSpan.FromSeconds(1));
            }

            mrevt.Set();
            Console.WriteLine("-------線程池中的第一個工作線程 發出信號----------");
        }
        private static void AsyncOperWait(CancellationTokenSource cts, bool isTimeOut)
        {
            Console.WriteLine("開始--線程池中的第二個工作線程。。。");

            if (isTimeOut)//判斷是否已經取消操作
            {
                cts.Cancel();
                Console.WriteLine("工作線程已經超時，並取消。  ID：{0}", Thread.CurrentThread.ManagedThreadId);
            }
            else
            {

                Console.WriteLine("-------線程池中的第二個工作線程 工作完成----------");
            }                


        }
    }
}

 2.程式結果如下。

       程式啟動之後按順序放入了一些長時間運行的操作，這個操作運行6秒，如果運行成功，則會設置一個ManualResetEvent信號。如果取消了這個操作，則這個操作會被丟棄。

       我們還註冊了第二個非同步操作，當從ManualResetEvent對象中接受了一個信號之後，這個非同步操作會被調用。如果第一個操作順利執行，則會設置信號。如果第一個操作執行超時，則會通過CancellationToken來取消第一個操作。

 註：當線程池中大量的操作被阻塞時，上面的方法就非常有用了。

 

六、     使用計時器

     使用Threading.Timer對象實現線程池中的周期性調用的非同步操作。

 1.代碼如下：

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading; 

namespace ThreadPoolDemo
{  

    class Program
    {
        static Timer timer;  

        static void Main(string[] args)
        {
            Console.WriteLine("開始測試線程池中通過計時器運行操作，輸入A停止計時器。。。");
            DateTime startTime = DateTime.Now;
            timer = new Timer(_=>TimesOperation(startTime),null,TimeSpan.FromSeconds(1),TimeSpan.FromSeconds(2));
            Thread.Sleep(6000);
            timer.Change(TimeSpan.FromSeconds(2), TimeSpan.FromSeconds(4)); 

            Console.WriteLine("。。。。。。。。。。。。。。。。");
            ConsoleKeyInfo key = Console.ReadKey();
            if (key.Key==ConsoleKey.A)
            {
                timer.Dispose();
            }
            Console.Read();
        }

        private static void TimesOperation(DateTime startTime)
        {
            TimeSpan time = DateTime.Now - startTime;
            Console.WriteLine("線程 {0} 從 {1} 開始 運行了 {2} 秒",
            Thread.CurrentThread.ManagedThreadId, startTime.ToString("yyyy-MM-dd HH:mm:ss"), time.Seconds); 

        }
    }
}

2.程式運行結果如下。

 

        程式啟動時，首先創建了一個timer，第一個參數是lambla表達式，將會線上程池中執行，第二個參數是null。然後調用TimerOperation方法，並給一個初始時間，並指定什麼時候會第一次運行TimerOperation，以及之後的再次調用間隔時間。

七、     使用BackgroundWorker組件

       本示例使用BackgroundWorker組件實現非同步操作。

       程式啟動時創建了一個BackgroundWorker對象實例，顯示的指示這個後臺工作線程支持取消操作及操作進度通知。

 1.代碼如下：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading;
namespace ThreadTPLDemo
{ 

    class Program
    {
        static Timer timer;   

        static void Main(string[] args)
        {
            Console.WriteLine("開始測試 BackgroundWorker。。。");
            BackgroundWorker bgwork = new BackgroundWorker();
            bgwork.WorkerReportsProgress = true;
            bgwork.WorkerSupportsCancellation = true; 

            bgwork.DoWork += worker_dowork;
            bgwork.ProgressChanged += worker_ProgressChanged;
            bgwork.RunWorkerCompleted += worker_Completed; 

            bgwork.RunWorkerAsync();//開始後臺運行        

            Console.WriteLine("。。。。。輸入C取消BackgroundWorker後臺組件。。。。。。。。。。。");
            do
            {
                ConsoleKeyInfo key = Console.ReadKey();
                if (key.KeyChar.ToString().ToUpper() == "C")
                {
                    bgwork.CancelAsync();
                }
            } while (bgwork.IsBusy);       

            Console.Read(); 

        }
        static void worker_dowork(object sender,DoWorkEventArgs e)
        {           
            Console.WriteLine("線程 {0}  開始 運行",
            Thread.CurrentThread.ManagedThreadId);
            int result = 0;
            var bgwork = (BackgroundWorker)sender;
            for (int i = 0; i < 100; i++)
            {
                if (bgwork.CancellationPending)//已經取消後臺操作
                {
                    e.Cancel = true;
                    return;
                }

                if (i%10==0)
                {
                    bgwork.ReportProgress(i);//顯示進度
                }
                Thread.Sleep(200);
                result += i;
            }

            e.Result = result;
        }
        static void worker_ProgressChanged(object sender,ProgressChangedEventArgs e)
        {
            Console.WriteLine("線程 {0}   已經完成工作量的 {1} %",          Thread.CurrentThread.ManagedThreadId,e.ProgressPercentage);
        }

        static void worker_Completed(object sender,RunWorkerCompletedEventArgs e)
        {
            Console.WriteLine("線程 {0} 已經執行結束！",
        Thread.CurrentThread.ManagedThreadId);
            if (e.Error!=null)
            {
                Console.WriteLine("線程 {0} 發生錯誤，錯誤信息：{1}",
     Thread.CurrentThread.ManagedThreadId,e.Error.Message);
            }
            else if (e.Cancelled)
            {
                Console.WriteLine("線程 {0} 已經取消",
   Thread.CurrentThread.ManagedThreadId);
            }
            else
            {
                Console.WriteLine("線程 {0} 執行成功，結果是：{1}",
   Thread.CurrentThread.ManagedThreadId, e.Result);
            }
        }
    }
}

2.程式正常執行結束，如下圖。

 

3.  程式執行的中途，人工干預，取消。如下圖。請看下圖中黃框的位置，我輸入了字母C，則線程被取消。

 

 在程式中我們定義了三個事件。

  1. DoWork事件，當一個後臺工作對象通過RunWorkerAsync啟動一個非同步操作時，將調用這個事件處理器。這個事件處理器會運行線上程池中，當運行結束，將運行結果做為參數傳遞給RunWorkerCompleted事件，同時觸發此事件。
  2. ProgressChanged事件，通過接收BackgroundWorker的ReportProgress方法傳遞過來的參數，顯示線程執行的進度。
  3. RunWorkerCompleted事件，在此事件中可以知道操作是成功完成，還是發生了錯誤，或是被取消。

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 從事人工智慧，應該瞄準這些崛起的企業
    我們在（人工智慧搶80萬工人的飯碗，卻增加了350萬個新崗位？！）文章中概述了人工智慧帶來的便利之處，那麼越來越多的人對人工智慧趨之若鶩，那人工智慧的就業崗位如何呢？薪資待遇如何呢？又有哪些實力強大的AI公司呢？ 最課程為大家分析各個招聘網站，python在智聯招聘上薪資待遇4k-50k不等；拉勾網 ...
  • COBBLER無人值守安裝
    cobbler-自動安裝系統 1.1 cobber簡介 1.1.1 cobbler說明 1.2 服務端部署 1.2.1 系統環境 系統：CentOS 7.4 ip: 外網：10.0.0.202 內網：172.16.1.202 1.2.2 安裝依賴包 1.2.3 修改配置文件 #備份、修改cobble ...
  • Linux系統中常見文件系統格式
    Windows常用的分區格式有三種，分別是FAT16、FAT32、NTFS格式。 在Linux操作系統里有Ext2、Ext3、Linux swap和VFAT四種格式。 FAT16： 作為一種文件名稱，FAT（File Allocation Table，文件分配表）自1981年問世以來，已經成為一個計 ...
  • 2017.11.18 手把手教你學51單片機-點亮LED
    In Doing We Learning 在操作中學習。如果只是光看教程，沒有實際的操作，對編程語言的理解很空泛，所以決定從單片機中學習C語言。 #include<reg52.h> //包含的頭文件。 sbit LED = P0^0; //這裡就是對P0寄存器進行位操作。相當於對P0^0位賦予了一個 ...
  • Nginx+Tomcat+Memcached實現會話保持
    會話保持的三種方式 Session sticky會話綁定：通過在前端調度器的配置中實現統一session發送至同一後髮端伺服器 Session cluster會話集群：通過配置Tomcat保持所有Tomcat的session的信息一致。 Session server 會話服務：將所有的session ...
  • 虛擬化之Xen簡介
    1》相關知識簡介： 1>常用的磁碟IO調度器： CFQ：完全公平隊列演算法； deadline：最後期限演算法； anticipatory：順序讀寫隊列演算法/預期演算法； NOOP：no operation，最簡單的調度演算法； 2>如何替換IO調度演算法：預設演算法為CFQ； /sys/block/<devi ...
  • KICKSTART無人值守安裝 - (字元界面操作)
    kickstart 部署 - 無人值守安裝系統（linux） ...
  • vuejs安裝篇
    1.安裝nodejs，自帶npm環境。 地址：https://nodejs.org/en/download/，Node.js 歷史版本下載地址：https://nodejs.org/dist/ 可自行選擇適合自己操作系統的版本。 安裝過程參見：http://www.runoob.com/nodejs ...
一周排行
    -Advertisement-
    Play Games
  • WPF 已知問題 監聽 WMI 事件導致觸摸失效
    示例項目結構 在 Visual Studio 中創建一個 WinForms 應用程式後，項目結構如下所示： MyWinFormsApp/ │ ├───Properties/ │ └───Settings.settings │ ├───bin/ │ ├───Debug/ │ └───Release/ ...
  • [STAThread]特性
    [STAThread] 特性用於需要與 COM 組件交互的應用程式，尤其是依賴單線程模型（如 Windows Forms 應用程式）的組件。在 STA 模式下，線程擁有自己的消息迴圈，這對於處理用戶界面和某些 COM 組件是必要的。 [STAThread] static void Main(stri ...
  • UWP WinUI3 傳入 AddHandler 的 RoutedEventHandler 類型與事件所需不匹配將拋出參數異常
    在WinForm中使用全局異常捕獲處理 在WinForm應用程式中，全局異常捕獲是確保程式穩定性的關鍵。通過在Program類的Main方法中設置全局異常處理，可以有效地捕獲並處理未預見的異常，從而避免程式崩潰。 註冊全局異常事件 [STAThread] static void Main() { / ...
  • .NET 多版本 WinForm 開源控制項庫 SunnyUI
    前言 給大家推薦一款開源的 Winform 控制項庫，可以幫助我們開發更加美觀、漂亮的 WinForm 界面。 項目介紹 SunnyUI.NET 是一個基於 .NET Framework 4.0+、.NET 6、.NET 7 和 .NET 8 的 WinForm 開源控制項庫，同時也提供了工具類庫、擴展 ...
  • .net core8 使用Swagger（附當前源碼）
    說明 該文章是屬於OverallAuth2.0系列文章，每周更新一篇該系列文章（從0到1完成系統開發）。 該系統文章，我會儘量說的非常詳細，做到不管新手、老手都能看懂。 說明：OverallAuth2.0 是一個簡單、易懂、功能強大的許可權+可視化流程管理系統。 有興趣的朋友，請關註我吧(*^▽^*) ...
  • WPF 什麼時候 VisualTreeHelper.GetDescendantBounds 將返回無窮大
    一、下載安裝 1.下載git 必須先下載並安裝git，再TortoiseGit下載安裝 git安裝參考教程：https://blog.csdn.net/mukes/article/details/115693833 2.TortoiseGit下載與安裝 TortoiseGit，Git客戶端，32/6 ...
  • C# 開源教程帶你輕鬆掌握數據結構與演算法
    前言 在項目開發過程中，理解數據結構和演算法如同掌握蓋房子的秘訣。演算法不僅能幫助我們編寫高效、優質的代碼，還能解決項目中遇到的各種難題。 給大家推薦一個支持C#的開源免費、新手友好的數據結構與演算法入門教程：Hello演算法。 項目介紹 《Hello Algo》是一本開源免費、新手友好的數據結構與演算法入門 ...
  • 第22篇 生成proto文件bat腳本
    1.生成單個Proto.bat內容 @rem Copyright 2016, Google Inc. @rem All rights reserved. @rem @rem Redistribution and use in source and binary forms, with or with ...
  • 記一次 .NET某上位機視覺程式 卡死分析
    一：背景 1. 講故事 前段時間有位朋友找到我，說他的窗體程式在客戶這邊出現了卡死，讓我幫忙看下怎麼回事？dump也生成了，既然有dump了那就上 windbg 分析吧。 二：WinDbg 分析 1. 為什麼會卡死 窗體程式的卡死，入口門檻很低，後續往下分析就不一定了，不管怎麼說先用 !clrsta ...
  • 醫學DICOM文件與PACS系統進行數據傳輸
    前言 人工智慧時代，人臉識別技術已成為安全驗證、身份識別和用戶交互的關鍵工具。 給大家推薦一款.NET 開源提供了強大的人臉識別 API，工具不僅易於集成，還具備高效處理能力。 本文將介紹一款如何利用這些API，為我們的項目添加智能識別的亮點。 項目介紹 GitHub 上擁有 1.2k 星標的 C# ...
所有分類