C# 多線程參數傳遞

以前使用多線程的時候,基本沒有遇到過參數傳遞的狀況,最近,接連遇到須要進行參數傳遞的多線程的使用。每次都要從新上網查一下,太麻煩了。爲了方便之後的使用,就把常常參閱的網上資料記錄下來。數據庫

原文地址以下:http://blog.csdn.net/jiankunking/article/details/45932289多線程

 

一、經過實體類來傳遞(能夠傳遞多個參數與獲取返回值),demo以下:異步

須要在線程中調用的函數:async

namespace ThreadParameterDemo
{
    public class FunctionClass
    {
        public static string TestFunction(string name, int age)
        {
            //內部處理省略
            return name + " 的年齡是:" + age;
        }
    }
}

經過實體來來封裝:函數

namespace ThreadParameterDemo
{
    /// <summary>
    /// 過渡類
    /// </summary>
    public class TransitionalClass
    {
        private string name = string.Empty;
        private int age;
        public string acceptResults = string.Empty;
        public TransitionalClass(string name, int age)
        {
            this.name = name;
            this.age = age;
        }

        public void TestFunction()
        {
            acceptResults = FunctionClass.TestFunction(this.name, this.age);
        }
    }
}

調用:工具

private void Form1_Load(object sender, EventArgs e)
{
    //實例化ThreadWithState類,爲線程提供參數  
    TransitionalClass tc = new TransitionalClass(" Jack", 42);
    // 建立執行任務的線程,並執行  
    Thread t = new Thread(new ThreadStart(tc.TestFunction));
    t.Start();
    //獲取返回值,經過 tc.acceptResults;  
}

小注:測試

必須注意IsBackground的問題,若是IsBackground爲false的,則Windows程序在退出的時候,不會爲你自動退出該線程。也就是實際上你的應用程序未結束。this

MSDN推薦:多線程方法調用提供參數的最好辦法是將目標方法包裹在類中,併爲該類定義字段,這些字段將被用做新線程的參數。 spa

這種方法的優勢是,任什麼時候候想要啓動新線程,均可以建立類的新實例,該實例帶有自身的參數。.net

可是,ThreadStart中的函數是沒有返回值和參數的

二、異步調用中的參數和返回值
能完美解決參數和返回值的是使用異步調用的方式。異步調用和Thread相比,一個最大的劣勢是不能控制其優先級。 

具體代碼以下:

        public delegate string delegateFunction(string name,int age);//委託
        delegateFunction df;
        private void Form1_Load(object sender, EventArgs e)
        {
            //指向須要調用的方法
            df = new delegateFunction(FunctionClass.TestFunction);
            string name = "my name";//輸入參數 
            int age = 19;
            IAsyncResult result = df.BeginInvoke(name,age, null, null);
            string myResult = df.EndInvoke(result);//用於接收返回值 
            MessageBox.Show(myResult);
        }

簡化:

        public Func<string, int, string>  df;//委託
        private void Form1_Load(object sender, EventArgs e)
        {
            //指向須要調用的方法
            df += FunctionClass.TestFunction;
            string name = "my name";//輸入參數 
            int age = 19;
            IAsyncResult result = df.BeginInvoke(name, age, null, null);
            string myResult = df.EndInvoke(result);//用於接收返回值 
            MessageBox.Show(myResult);
        }

小注:

經過這種方式生成新線程是運行在後臺的(background),優先級爲normal

三、使用 BackgroundWorker

多線程返回值最簡單方法是:使用 BackgroundWorker 組件來管理線程,在任務完成時引起事件,而後用事件處理程序處理結果。

小注:
BackgroundWorker 組件用來執行諸如數據庫事務、文件下載等耗時的異步操做。
在應用程序中添加一個BackgroundWorker實例,若是用的是VS,能夠從工具上直接拖到應用程序:

BackgroundWorker backgroundWorker1 = new BackgroundWorker();  

爲了開始在後臺操做,必須調用BackgroundWorker的RunWorkerAsync()方法,當調用此方時,BackgroundWorker 經過觸發DoWork 事件,開始執行後臺操做,DoWork 事件的代碼是在另外一個線程裏執行的。
       當後臺操做完成之後,不管是completed 仍是cancelled,則RunWorkerCompleted 事件被觸發,經過此方法能夠將後臺操做的完成結果反饋給用戶。
       另外,經過RunWorkerCompletedEventArgs實例的Cancelled 屬性,以判斷是不是Cancel操做使得後臺操做終止。 

具體demo以下:

using System;
using System.Windows.Forms;

namespace WindowsFormsApplication1
{
    public partial class Form2 : Form
    {
        public Form2()
        {
            InitializeComponent();
        }

        private void Form2_Load(object sender, EventArgs e)
        {
            //TransitionalClass tc = new TransitionalClass("xiaoming", 10);
            //ThreadPool.QueueUserWorkItem(new WaitCallback(TransitionalClass.TestFunction), tc);
        }

        private void button1_Click(object sender, EventArgs e)
        {
            this.TestArea2();
        }

        private System.ComponentModel.BackgroundWorker BackgroundWorker1
    = new System.ComponentModel.BackgroundWorker();

        private void TestArea2()
        {
            InitializeBackgroundWorker();

            AreaClass2 AreaObject2 = new AreaClass2();
            AreaObject2.Base = 30;
            AreaObject2.Height = 40;

            // Start the asynchronous operation.
            BackgroundWorker1.RunWorkerAsync(AreaObject2);
        }

        private void InitializeBackgroundWorker()
        {
            // Attach event handlers to the BackgroundWorker object.
            BackgroundWorker1.DoWork +=
                new System.ComponentModel.DoWorkEventHandler(BackgroundWorker1_DoWork);
            BackgroundWorker1.RunWorkerCompleted +=
                new System.ComponentModel.RunWorkerCompletedEventHandler(BackgroundWorker1_RunWorkerCompleted);
        }

        private void BackgroundWorker1_DoWork(
            object sender,
            System.ComponentModel.DoWorkEventArgs e)
        {
            //在執行DoWork 事件時,DoWorkEventArgs 實例的Result 屬性,返回值到用戶;在RunWorkerCompleted 事件裏,RunWorkerCompletedEventArgs 實例的Result 屬性接收值;
            AreaClass2 AreaObject2 = (AreaClass2)e.Argument;
            // Return the value through the Result property.
            e.Result = AreaObject2.CalcArea();
        }

        private void BackgroundWorker1_RunWorkerCompleted(
            object sender,
            System.ComponentModel.RunWorkerCompletedEventArgs e)
        {
            // Access the result through the Result property. 
            double Area = (double)e.Result;
            MessageBox.Show("The area is: " + Area.ToString());
        }
    }
}

四、若是沒有返回值的時候,能夠經過匿名函數的方式簡化代碼

FunctionClass類新增,測試函數以下:

        public static void TestFunction2(string name, int age)
        {
            //內部處理省略            
        }

調用以下:

        private void Form1_Load(object sender, EventArgs e)
        {
            Thread t1 = new Thread(new ThreadStart(delegate
            {
                FunctionClass.TestFunction2("eee", 5);
            }));
            t1.Start();          
        }

小注:

若是經過WCF來調用的話,應該把起線程的函數放到服務端,若是放到客戶端,很容易由於WCF客戶端的時間限制,形成形成主程序的莫名崩潰。

崩潰的緣由主要是客戶端wcf響應時間是有限制。

相關文章
相關標籤/搜索