第六章-异步与多线程编程PPT优秀课件

1、.net课程系列C#高级编程.NET方向 第二学期课程第六章 异步与多线程编程Newture新程教育本章目录引言引言进程与线程进程与线程进程与线程BeginInvoke和EndInvokeclass Program public delegate void PrintDelegate(string content); static void Main(string args) PrintDelegate printDelegate = Program.Print; IAsyncResult result = printDelegate.BeginInvoke(hello world, null

2、, null); printDelegate.EndInvoke(result); public static void Print(string content) Console.WriteLine(打印中n+content); System.Threading.Thread.Sleep(2000); IAsyncResult接口和AsyncResult类public interface IAsyncResult object AsyncState get; WaitHandle AsyncWaitHandle get; bool CompletedSynchronously get; bo

3、ol IsCompleted get; 属性返回类型说明IAsyncResult接口和AsyncResult类异步编程的4种方法 class Program public delegate void PrintDelegate(string content); static void Main(string args) int threadId = Thread.CurrentThread.ManagedThreadId; PrintDelegate printDelegate = Program.Print; Console.WriteLine(主线程Id:+threadId+t+打印方法开

4、始调用); IAsyncResult result = printDelegate.BeginInvoke(hello world, null, null); printDelegate.EndInvoke(result); public static void Print(string content) int threadId = Thread.CurrentThread.ManagedThreadId; Console.WriteLine(当前线程Id：+threadId); Console.WriteLine(打印中n+content); Thread.Sleep(2000); Con

5、sole.WriteLine(当前线程Id： + threadId+t+打印方法调用完毕); 异步编程的4种方法异步编程的4种方法 class Program public delegate void PrintDelegate(string content); static void Main(string args) int threadId = Thread.CurrentThread.ManagedThreadId; PrintDelegate printDelegate = Program.Print; Console.WriteLine(主线程Id:+threadId+t+打印方法

6、开始调用); IAsyncResult result = printDelegate.BeginInvoke(hello world, null, null); result.AsyncWaitHandle.WaitOne(5000, false); 异步编程的4种方法 class Program public delegate void PrintDelegate(string content); static void Main(string args) int threadId = Thread.CurrentThread.ManagedThreadId; PrintDelegate p

7、rintDelegate = Program.Print; Console.WriteLine(主线程Id:+threadId+t+打印方法开始调用); IAsyncResult result = printDelegate.BeginInvoke(hello world, null, null); while (!result.IsCompleted) Console.WriteLine(.); Thread.Sleep(500); 异步编程的4种方法异步编程的4种方法class Program public delegate void PrintDelegate(string conten

8、t); static void Main(string args) int threadId = Thread.CurrentThread.ManagedThreadId; PrintDelegate printDelegate = Program.Print; Console.WriteLine(主线程Id: + threadId + t + 打印方法开始调用); IAsyncResult result = printDelegate.BeginInvoke(hello world, PrintComplete, printDelegate); Thread.Sleep(10000); pu

9、blic static void PrintComplete(IAsyncResult result) int threadId = Thread.CurrentThread.ManagedThreadId; (result.AsyncState as PrintDelegate).EndInvoke(result); Console.WriteLine(当前线程Id： + threadId + t + 打印方法调用完毕) 多线程编程Thread类Thread类Thread类 class Program static void Main(string args) Console.WriteLi

10、ne(主线程：0,Thread.CurrentThread.ManagedThreadId); Thread thread1 = new Thread(Print); thread1.Start(); Thread thread2 = new Thread(PrintEx); thread2.Start(测试打印); public static void Print() int threadId = Thread.CurrentThread.ManagedThreadId; Console.WriteLine(当前线程id：0t1, threadId, DateTime.Now.ToShort

11、TimeString(); public static void PrintEx(object content) int threadId = Thread.CurrentThread.ManagedThreadId; Console.WriteLine(当前线程id：0t1, threadId, content); Thread类Thread类Thread类使用线程池使用线程池使用线程池使用线程池class Program static void Main(string args) ThreadPool.QueueUserWorkItem(Counter); ThreadPool.Queue

12、UserWorkItem(Counter,test); Console.WriteLine(线程ID=0主线程启动, Thread.CurrentThread.ManagedThreadId); Thread.Sleep(500); Console.WriteLine(主线程退出); private static void Counter(object state) Console.WriteLine(开始计数，从 1 到 100：); Console.WriteLine(传入的参数值为：0,state); for (int counter = 0; counter 100; counter+

13、) if (null = state)Console.WriteLine(线程ID=0 1,Thread.CurrentThread.ManagedThreadId,counter); elseConsole.WriteLine(线程ID=0 1, Thread.CurrentThread.ManagedThreadId, state);Thread.Sleep(100); 线程同步 class Program int count; public int Max get; set; public void Increase() for (int i = 0; i Max; i+) count+

14、; static void Main(string args) Thread threads = new Thread500; Program p = new Program() Max=10000 ; for (int i = 0; i threads.Length; i+) threadsi = new Thread(p.Increase); threadsi.Start(); for (int i = 0; i threads.Length; i+) threadsi.Join(); Console.WriteLine(0:N0, p.count); 线程同步 public void I

15、ncrease() for (int i = 0; i Max; i+) lock (this) count+; private object _lock = new object(); public void Increase() for (int i = 0; i Max; i+) lock (_lock) count+; 线程同步 private object _lock = new object(); public void Increase() for (int i = 0; i Max; i+) Monitor.Enter(_lock); try count+; finally M

16、onitor.Exit(_lock); 死锁public void Lock1() Console.WriteLine(线程0启动，执行Lock1(),Thread.CurrentThread.ManagedThreadId); lock (_lock_1) Thread.Sleep(1000); lock (_lock_2) Console.WriteLine(线程0从Lock1()退出,Thread.CurrentThread.ManagedThreadId);public void Lock2() Console.WriteLine(线程0启动，执行Lock2(), Thread.CurrentThread.ManagedThreadId); lock (_lock_2) Thread.Sleep(2000); lock (_lock_1) Console.WriteLine(线程0从Lock2()退出, Thr