首页 > 代码库 > BeginInvoke()使用
BeginInvoke()使用
using System;using System.Collections.Generic;using System.Linq;using System.Text;using System.IO;using System.Runtime.Serialization.Formatters.Binary;using System.Xml;using System.Threading; namespace ConsoleApplication1{ class Program { static void Main(string[] args) { Console.WriteLine("Client application is starting!"); Thread.CurrentThread.Name = "Main Thread"; Cal cal = new Cal(); AddDelegate del = new AddDelegate(cal.Add); // 需要保存 IAsyncResult 对象以便后边条用EndInvoke方法时作参数传递 IAsyncResult asyncResult = del.BeginInvoke(5, 6, null, null); // 做某些其它的事情,模拟需要执行 3 秒钟 for (int i = 1; i <= 3; i++) { Thread.Sleep(TimeSpan.FromSeconds(i)); Console.WriteLine("{0}: Client executed {1} second(s).", Thread.CurrentThread.Name, i); } // 传递 IAsyncResult 对象 int rtnVal = del.EndInvoke(asyncResult); Console.WriteLine("Result: {0}\n", rtnVal); Console.WriteLine("\nPress any key to exit..."); Console.ReadLine(); } public delegate int AddDelegate(int a, int b); public class Cal { public int Add(int a, int b) { if (Thread.CurrentThread.IsThreadPoolThread) { Thread.CurrentThread.Name = "Pool Thread"; } Console.WriteLine("Method invoked!"); // 做某些其它的事情,模拟需要执行 2 秒钟 for (int i = 0; i < 2; i++) { Thread.Sleep(TimeSpan.FromSeconds(1)); Console.WriteLine("{0}: Add executed {1} second(s).", Thread.CurrentThread.Name, i); } Console.WriteLine("Method complete!"); return a + b; } } }}
BeginInvoke()使用
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。