Java進擊C#——語法之多線程，

Java進擊C#——語法之多線程，

上一章中筆者對C#一些獨有的語法點進行講解，相信也可以看C#的一些神奇之處。那麼本章主要是放在多線程這方面的知識。不管是C#還是JAVA在開發過程或多或少都會用到關於多線程的編程。當然筆者不可能把多線程的知識點講的很全面。筆者這裡只是講一些筆者常用到的。如果有興趣的朋友，筆者希望主動性去查找一下資料。

對於Thread類相信JAVA的朋友一點也不陌生。在一點上C#到是跟JAVA很類似。只是在使用上有一定差別。首先要明白C#的多線程功能一般都是在命名空System.Threading下面。至於什麼是線程，進程又是什麼這樣子的問題。筆者就不多說了。相信大家都明白。筆者還是喜歡直接一點。讓我們看一下代碼進行學習吧。

C#：

 1  class Program
 2     {
 3         static void Main(string[] args)
 4         {
 5             Thread myThread1 = new Thread(() =>
 6             {
 7                 Console.WriteLine("這是一個lambda表達式 創建線程");
 8             });
 9 
10             Thread myThread2 = new Thread(ThreadStartImp);
11 
12             Thread myThread3 = new Thread((object obj) =>
13             {
14                 Console.WriteLine("這是一個lambda表達式創建有參數的線程 參數：" + obj.ToString());
15             });
16 
17             myThread1.Start();
18             myThread2.Start();
19             myThread3.Start("aomi");
20 
21         }
22 
23         public static void ThreadStartImp()
24         {
25             Console.WriteLine("這是一個用方法創建線程");
26         }
27 
28 
29     }

筆者在上面創建三個線程代碼。myThread1和myThread2是同一種線程。即是沒有參數的線程。myThread3是有參數的線程。不管是不是有參數。使用方式基本是一樣子的。有參數的話，就是調用Start方法的時候給他傳入一個參數即可。我們可以看到使用上跟JAVA有一個很大的差別。JAVA的Thread類構造函數的參數傳入Runnable接口。可惜C#不是。如下代碼。

C#:

public Thread(ParameterizedThreadStart start);
public Thread(ThreadStart start);
public Thread(ParameterizedThreadStart start, int maxStackSize);
public Thread(ThreadStart start, int maxStackSize);

這段代碼是源碼裡面的。選中Thread類按F12就可以大概的查看Thread類的結構。我們看可以看到四個構造函數。我們常常用到只是倆個：Thread(ParameterizedThreadStart start)和Thread(ThreadStart start)。剛剛看到的時候我一直以為ThreadStart會跟JAVA的Runnable接口一樣子。只到按F12進入查看一下結構才明白大錯特錯。如下代碼

C#:

[ComVisible(true)]
public delegate void ThreadStart();

C#:

[ComVisible(false)]
public delegate void ParameterizedThreadStart(object obj);

我們可以清楚的看到一個關鍵字delegate。相信有看過上一章的朋友都知道他是跟事件有關系。沒有錯。就是定義一個委托類型。以便將來用於傳方法。所以我們可以明白這邊的Thread類的構造函數的參數只能傳入方法。那麼相信筆者上面的三個線程的定義的意義也很明顯了。

myThread1線程：筆者用的是lambda表達式來創建。lambda表達是什麼上一章也有簡單的講到。

myThread2線程：外面定義一個方法用於實現多線程。這方法可以是一個靜態方法也可以是一個對象的方法。關鍵字static的功能跟JAVA一樣子。

myThread3線程：實現有一個有參數的多線程。

上面只是講到關於Thread類的使用。對於Thread類對象裡面的一些方法的話，筆者就不多介紹了。大至跟JAVA的Thread類一樣子。如Interrupt方法。請讀者們自行查看。

當我們談到多線程池的時候，相信大家都知道是什麼東西。C#用的是ThreadPool類。只是可惜筆者在JAVA這邊用到多線程池的機會不多。所以也不清楚JAVA中的ThreadPoolExecutor類和Executors類跟C#的ThreadPool類相差多少。不過有興趣的朋友可以看一下。筆者這裡還是講一下ThreadPool類的使用吧。ThreadPool類更多的時候有一點像工具類一樣子。如下面代碼。

C#：

 class Program
    {
        static void Main(string[] args)
        {
            ThreadPool.QueueUserWorkItem((obj) =>
            {
                Console.WriteLine("這是一個lambda表達式創建有參數的線程 參數：" + obj.ToString());
            });

            ThreadPool.QueueUserWorkItem(WaitCallbackImp);

        }

        public static void WaitCallbackImp(object obj)
        {
            Console.WriteLine("這是一個用方法創建線程");
        }
    }

上面的代碼跟上面的Thread類有一點類似。可是本質上卻有很大的差別。這裡是用多線程池的。另外對於多線程池的設置。只要ThreadPool.XXXXX裡面有很多方法讓你去設置。

如果你們有用上面的Thread類你就會發現，有時候當線程在運行中的時候很難停止。但是如果你用了Task類的話，你就會發現這個難點已經不存在了。我也不清楚C#為什麼會引入Task類。可能就是因為Thread類和ThreadPool類太難控制吧。那麼這不是筆者關注的問題。讓我們看一下Task類是如何使用的。Task類是中文常常叫做任務。所以就是有一種說法。是單任務還是多任務。為什麼筆者會這樣子講呢？如下。

1.單任務。即是一個Task類實例。這個時候就比較簡單。代碼如下

  class Program
    {
        static void Main(string[] args)
        {
            CancellationTokenSource cts = new CancellationTokenSource();//用於中途取消
            Task myTask = new Task((obj) =>
            {
                Console.WriteLine("這是一個單任務");
            }, cts);
            myTask.Start();

            Console.ReadKey();
        }
    }

這裡面筆者只用到了一個類CancellationTokenSource。這個類就是用於取消任務。還是讓筆者寫一個例子吧。

 class Program
    {
        static void Main(string[] args)
        {
            CancellationTokenSource cts = new CancellationTokenSource();//用於中途取消
            Task myTask = new Task((obj) =>
            {
                
                Console.WriteLine("這是一個單任務");

                Thread.Sleep(20000);//讓他睡一段時間
            }, cts);

            myTask.Start();

            if (cts.IsCancellationRequested)//判斷是否取消
            {
                cts.Cancel();
            }

            Console.ReadKey();
        }
    }

2.多任務。就是多個Task類的實例進行配合。這個時候就有誰先做。誰後做的問題。

 class Program
    {
        static void Main(string[] args)
        {
            CancellationTokenSource cts1 = new CancellationTokenSource();//用於中途取消
            Task myTask1 = new Task((obj) =>
            {
                
                Console.WriteLine("這是一個單任務");

                //Thread.Sleep(20000);//讓他睡一段時間
            }, cts1);

            CancellationTokenSource cts2 = new CancellationTokenSource();//用於中途取消

            myTask1.ContinueWith((task) => {

                Console.WriteLine("myTask2任務");
            }, cts2.Token);

            myTask1.Start();

            //if (cts1.IsCancellationRequested)//判斷是否取消
            //{
            //    cts1.Cancel();
            //}

            Console.ReadKey();
        }
    }

上面的ContinueWith方法就是表示：當myTask1結束之後，就可以繼續紅色的代碼。即是另一個Task任務。除了上面的實例之後，還有一種用法。代碼如下。

CancellationTokenSource cts3 = new CancellationTokenSource();//用於中途取消
Task.Factory.StartNew((obj) =>
{

   Console.WriteLine("這是一個用的Factory單任務");

}, cts3);

看樣了不用筆者多說了。有一點類似於多線程池的概念。只是注意Task.Factory裡面還有一些很好用的功能。ContinueWhenAll方法就是一個很好的體現。和上面的ContinueWith有一個像。即是所以的task結束之後才執行對應的最後一個task。請用Task.Factory.讓他提示進行學習。如果不提示的話，寫完上面的"ask.Factory."之後按Ctrl+J。裡面有各種方法讓你學習。

本章主要是對多線程常用的一些知識進行講解。筆者並沒有對他們進行詳細的說明。所以希望讀者們可以根據筆者所講的繼續深入下去。