如何并行运行两个线程?

我点击一个按钮启动两个线程,每个线程调用一个单独的例程,每个例程将打印线程名称和i值。

程序运行完美,但我看到Thread1()函数先运行然后Thread2()例程启动,但我尝试并行运行Thread2()Thread2() 。 我在哪里弄错了?

 private void button1_Click(object sender, EventArgs e) { Thread tid1 = new Thread(new ThreadStart(Thread1)); Thread tid2 = new Thread(new ThreadStart(Thread2)); tid1.Start(); tid2.Start(); MessageBox.Show("Done"); } public static void Thread1() { for (int i = 1; i <= 10; i++) { Console.Write(string.Format("Thread1 {0}", i)); } } public static void Thread2() { for (int i = 1; i <= 10; i++) { Console.Write(string.Format("Thread2 {0}", i)); } } 

这样我实现了我的目标。 这是代码

 using System.Threading.Tasks; using System.Threading; class Program { static void Main(string[] args) { Task task1 = Task.Factory.StartNew(() => doStuff("Task1")); Task task2 = Task.Factory.StartNew(() => doStuff("Task2")); Task task3 = Task.Factory.StartNew(() => doStuff("Task3")); Task.WaitAll(task1, task2, task3); Console.WriteLine("All threads complete"); Console.ReadLine(); } static void doStuff(string strName) { for (int i = 1; i <= 3; i++) { Console.WriteLine(strName + " " + i.ToString()); Thread.Yield(); } } } 

我从这个urlhttps://msdn.microsoft.com/en-us/library/dd460705%28v=vs.110%29.aspx获得了另一个很好的Task库示例

这是代码

 using System.Threading; using System.Threading.Tasks; using System.Net; class Program { static void Main() { // Retrieve Darwin's "Origin of the Species" from Gutenberg.org. string[] words = CreateWordArray(@"http://www.gutenberg.org/files/2009/2009.txt"); #region ParallelTasks // Perform three tasks in parallel on the source array Parallel.Invoke(() => { Console.WriteLine("Begin first task..."); GetLongestWord(words); }, // close first Action () => { Console.WriteLine("Begin second task..."); GetMostCommonWords(words); }, //close second Action () => { Console.WriteLine("Begin third task..."); GetCountForWord(words, "species"); } //close third Action ); //close parallel.invoke Console.WriteLine("Returned from Parallel.Invoke"); #endregion Console.WriteLine("Press any key to exit"); Console.ReadKey(); } #region HelperMethods private static void GetCountForWord(string[] words, string term) { var findWord = from word in words where word.ToUpper().Contains(term.ToUpper()) select word; Console.WriteLine(@"Task 3 -- The word ""{0}"" occurs {1} times.", term, findWord.Count()); } private static void GetMostCommonWords(string[] words) { var frequencyOrder = from word in words where word.Length > 6 group word by word into g orderby g.Count() descending select g.Key; var commonWords = frequencyOrder.Take(10); StringBuilder sb = new StringBuilder(); sb.AppendLine("Task 2 -- The most common words are:"); foreach (var v in commonWords) { sb.AppendLine(" " + v); } Console.WriteLine(sb.ToString()); } private static string GetLongestWord(string[] words) { var longestWord = (from w in words orderby w.Length descending select w).First(); Console.WriteLine("Task 1 -- The longest word is {0}", longestWord); return longestWord; } // An http request performed synchronously for simplicity. static string[] CreateWordArray(string uri) { Console.WriteLine("Retrieving from {0}", uri); // Download a web page the easy way. string s = new WebClient().DownloadString(uri); // Separate string into an array of words, removing some common punctuation. return s.Split( new char[] { ' ', '\u000A', ',', '.', ';', ':', '-', '_', '/' }, StringSplitOptions.RemoveEmptyEntries); } #endregion } 

它们并行运行。 这是经过调整的代码,可以更好地查看:

  private void test() { Thread tid1 = new Thread(new ThreadStart(Thread1)); Thread tid2 = new Thread(new ThreadStart(Thread2)); tid1.Start(); tid2.Start(); Console.Write(string.Format("Done")); } static void Thread1() { for (int i = 1; i <= 10; i++) { Console.Write(string.Format("Thread1 {0}", i)); Thread.Yield(); } } static void Thread2() { for (int i = 1; i <= 10; i++) { Console.Write(string.Format("Thread2 {0}", i)); Thread.Yield(); } } 

这里输出:DoneThread1 1Thread2 1Thread1 2Thread2 2Thread1 3Thread2 3Thread1 4Thread2 4Thread1 5Thread2 5Thread1 6Thread2 6Thread1 7Thread2 7Thread1 8Thread2 8Thread1 9Thread2 9Thread1 10Thread2 10

您可以使用Parallel.Invoke()方法。 但它只适用于.Net 4及更高版本。

  public ParallelDemo() { Parallel.Invoke( () => { PrintCount(-10000, 0); }, () => { PrintCount(1, 10000); } ); } public void PrintCount(int LowLimit , int UpperLimit) { for (int i = LowLimit; i <=UpperLimit; i++) { Console.WriteLine("> {0}" , i); } } 

输出(所有系统都不一样): 截图

它们并行运行,但开始的时间延迟大于每个线程本身的运行时间。 在每个Console.WriteLine之后延迟Console.WriteLine ,你会看到。

顺便说一下,启动新线程的更优雅方式是

 ThreadPool.QueueUserWorkItem(delegate { //code here });