这篇文章主要介绍了C#BeginInvoke实现异步编程方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
BeginInvoke实现异步编程的三种模式:
1.等待模式
在发起了异步方法以及做了一些其他处理之后,原始线程就中断并且等异步方法完成之后再继续;
eg:
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;namespace BeginInvokeDemo
{
public delegate int myDelegate(int num1,int num2); //声明委托
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
} private int Cal_Task1(int num1, int num2) //方法一
{
Thread.Sleep(3000); //进程延时3S,延长执行时间
return num1 + num2;
}
private int Cal_Task2(int num1, int num2) //方法二
{
return num1 + num2;
}
private void button_Calculate_Click(object sender, EventArgs e)
{
myDelegate objTest = new myDelegate(Cal_Task1); //定义委托变量,引用任务1
IAsyncResult iar = objTest.BeginInvoke(3,4,null,null); //异步调用
textBox_Result1.Text = "计算中..."; textBox_Result2.Text = Cal_Task2(5,6).ToString(); //同时可以并行其他任务 int result = objTest.EndInvoke(iar); //获取异步执行结果
//委托类型的EndInvoke()方法:借助IAsyncResult接口对象,不断查询异步调用是否结束。
//该方法知道被异步调用的方法所有的参数,所以,异步调用结束后,取出异步调用结果作为返回值
textBox_Result1.Text = result.ToString();
}
}
}
2.轮询模式
原始线程定期检查发起的线程是否完成,如果没有则可以继续做一些其他事情;
eg:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;namespace ConsoleApplication2
{
delegate int MyDel(int num1,int num2);
class Program
{
static void Main(string[] args)
{
MyDel del = new MyDel(Sum);
IAsyncResult iar = del.BeginInvoke(3,4,null,null);
Console.WriteLine("After BeginInvoke"); while(!iar.IsCompleted)
{
Console.WriteLine("Not Done"); //继续处理
for (long i = 0; i < 10000000; i++)
; //空语句
}
Console.WriteLine("Done"); int result = del.EndInvoke(iar);
Console.WriteLine("Result:{0}",result); Console.ReadLine();
} static int Sum(int x,int y)
{
Console.WriteLine(" Inside Sum");
Thread.Sleep(100); return x + y;
}
}
}
3.回调模式
原始线程一直执行,无需等待或检查发起的线程是否完成。
在发起的线程中引用方法完成之后,发起的线程就会调用回调方法,由回调方法再调用EndInvoke之前处理异步方法的结果。
eg:
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;namespace _02_AsyncCallBackDemo
{
public partial class FrmCalllBack : Form
{
public FrmCalllBack()
{
InitializeComponent(); //【3】初始化委托变量
this.objMyCal = new MyCalculator(ExecuteTask); //也可以直接使用Lambda表达式
//this.objMyCal = (num, ms) =>
//{
// System.Threading.Thread.Sleep(ms);
// return num * num;
/