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

本章簡言

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

Thread類

對於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方法。請讀者們自行查看。

ThreadPool類

當咱們談到多線程池的時候，相信你們都知道是什麼東西。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裏面有不少方法讓你去設置。

Task類

若是大家有用上面的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。裏面有各類方法讓你學習。

本章總結

本章主要是對多線程經常使用的一些知識進行講解。筆者並無對他們進行詳細的說明。因此但願讀者們能夠根據筆者所講的繼續深刻下去。