c#使用多线程的几种方式示例详解
(1)不需要传递参数,也不需要返回参数
threadstart是一个委托，这个委托的定义为void threadstart()，没有参数与返回值。
class program
{
static void main(string[] args)
{
for (int i = 0; i < 30; i++)
{
threadstart threadstart = new threadstart(calculate);
thread thread = new thread(threadstart);
thread.start();
}
thread.sleep(2000);
console.read();
}
public static void calculate()
{
datetime time = datetime.now;//得到当前时间
random ra = new random();//随机数对象
thread.sleep(ra.next(10,100));//随机休眠一段时间
console.writeline(time.minute + ":" + time.millisecond);
}
}
(2)需要传递单个参数
parameterthreadstart委托定义为void parameterizedthreadstart(object state)，有一个参数但是没有返回值。
class program
{
static void main(string[] args)
{
for (int i = 0; i < 30; i++)
{
parameterizedthreadstart tstart = new parameterizedthreadstart(calculate);
thread thread = new thread(tstart);
thread.start(i*10+10);//传递参数
}
thread.sleep(2000);
console.read();
}
public static void calculate(object arg)
{
random ra = new random();//随机数对象
thread.sleep(ra.next(10, 100));//随机休眠一段时间
console.writeline(arg);
}
}
(3)使用专门的线程类(常用)
使用线程类可以有多个参数与多个返回值，十分灵活！
class program
{
static void main(string[] args)
{
mythread mt = new mythread(100);
threadstart threadstart = new threadstart(mt.calculate);
thread thread = new thread(threadstart);
thread.start();
//等待线程结束
while (thread.threadstate != threadstate.stopped)
{
thread.sleep(10);
}
console.writeline(mt.result);//打印返回值
console.read();
}
}
public class mythread//线程类
{
public int parame { set; get; }//参数
public int result { set; get; }//返回值
//构造函数
public mythread(int parame)
{
this.parame = parame;
}
//线程执行方法
public void calculate()
{
random ra = new random();//随机数对象
thread.sleep(ra.next(10, 100));//随机休眠一段时间
console.writeline(this.parame);
this.result = this.parame * ra.next(10, 100);
}
}
(4)使用匿名方法(常用)
使用匿名方法启动线程可以有多个参数和返回值，而且使用非常方便！
class program
{
static void main(string[] args)
{
int parame = 100;//当做参数
int result = 0;//当做返回值
//匿名方法
threadstart threadstart = new threadstart(delegate()
{
random ra = new random();//随机数对象
thread.sleep(ra.next(10, 100));//随机休眠一段时间
console.writeline(parame);//输出参数
result = parame * ra.next(10, 100);//计算返回值
});
thread thread = new thread(threadstart);
thread.start();//多线程启动匿名方法
//等待线程结束
while (thread.threadstate != threadstate.stopped)
{
thread.sleep(10);
}
console.writeline(result);//打印返回值
console.read();
}
}
(5)使用委托开启多线程(多线程深入)
1、用委托(delegate)的begininvoke和endinvoke方法操作线程
begininvoke方法可以使用线程异步地执行委托所指向的方法。然后通过endinvoke方法获得方法的返回值（endinvoke方法的返回值就是被调用方法的返回值），或是确定方法已经被成功调用。
class program
{
private delegate int newtaskdelegate(int ms);
private static int newtask(int ms)
{
console.writeline("任务开始");
thread.sleep(ms);
random random = new random();
int n = random.next(10000);
console.writeline("任务完成");
return n;
}
static void main(string[] args)
{
newtaskdelegate task = newtask;
iasyncresult asyncresult = task.begininvoke(2000, null, null);
//endinvoke方法将被阻塞2秒
int result = task.endinvoke(asyncresult);
console.writeline(result);
console.read();
}
}
2、使用iasyncresult.iscompleted属性来判断异步调用是否完成
class program
{
private delegate int newtaskdelegate(int ms);
private static int newtask(int ms)
{
console.writeline("任务开始");
thread.sleep(ms);
random random = new random();
int n = random.next(10000);
console.writeline("任务完成");
return n;
}
static void main(string[] args)
{
newtaskdelegate task = newtask;
iasyncresult asyncresult = task.begininvoke(2000, null, null);
//等待异步执行完成
while (!asyncresult.iscompleted)
{
console.write("*");
thread.sleep(100);
}
// 由于异步调用已经完成，因此， endinvoke会立刻返回结果
int result = task.endinvoke(asyncresult);
console.writeline(result);
console.read();
}
}
3、使用waitone方法等待异步方法执行完成
waitone的第一个参数表示要等待的毫秒数，在指定时间之内，waitone方法将一直等待，直到异步调用完成，并发出通知，waitone方法才返回true。当等待指定时间之后，异步调用仍未完成，waitone方法返回false，如果指定时间为0，表示不等待，如果为-1，表示永远等待，直到异步调用完成。
class program
{
private delegate int newtaskdelegate(int ms);
private static int newtask(int ms)
{
console.writeline("任务开始");
thread.sleep(ms);
random random = new random();
int n = random.next(10000);
console.writeline("任务完成");
return n;
}
static void main(string[] args)
{
newtaskdelegate task = newtask;
iasyncresult asyncresult = task.begininvoke(2000, null, null);
//等待异步执行完成
while (!asyncresult.asyncwaithandle.waitone(100, false))
{
console.write("*");
}
int result = task.endinvoke(asyncresult);
console.writeline(result);
console.read();
}
}
4、使用回调方式返回结果
要注意的是“my.begininvoke(3,300, methodcompleted, my)”，begininvoke方法的参数传递方式：
前面一部分(3,300)是其委托本身的参数。
倒数第二个参数(methodcompleted)是回调方法委托类型，他是回调方法的委托，此委托没有返回值，有一个iasyncresult类型的参数，当method方法执行完后，系统会自动调用methodcompleted方法。
最后一个参数(my)需要向methodcompleted方法中传递一些值，一般可以传递被调用方法的委托，这个值可以使用iasyncresult.asyncstate属性获得。
class program
{
private delegate int mymethod(int second, int millisecond);
//线程执行方法
private static int method(int second, int millisecond)
{
console.writeline("线程休眠" + (second * 1000 + millisecond) + "毫秒");
thread.sleep(second * 1000 + millisecond);
random random = new random();
return random.next(10000);
}
//回调方法
private static void methodcompleted(iasyncresult asyncresult)
{
if (asyncresult == null || asyncresult.asyncstate == null)
{
console.writeline("回调失败！！！");
return;
}
int result = (asyncresult.asyncstate as mymethod).endinvoke(asyncresult);
console.writeline("任务完成，结果：" + result);
}
static void main(string[] args)
{
mymethod my = method;
iasyncresult asyncresult = my.begininvoke(3,300, methodcompleted, my);
console.writeline("任务开始");
console.read();
}
}
5、其他组件的beginxxx和endxxx方法
在其他的.net组件中也有类似begininvoke和endinvoke的方法，如system.net.httpwebrequest类的begingetresponse和endgetresponse方法。其使用方法类似于委托类型的begininvoke和endinvoke方法，例如：
class program
{
//回调函数
private static void requestcompleted(iasyncresult asyncresult)
{
if (asyncresult == null || asyncresult.asyncstate==null)
{
console.writeline("回调失败");
return;
}
httpwebrequest hwr = asyncresult.asyncstate as httpwebrequest;
httpwebresponse response = (httpwebresponse)hwr.endgetresponse(asyncresult);
streamreader sr = new streamreader(response.getresponsestream());
string str = sr.readtoend();
console.writeline("返回流长度："+str.length);
}
static void main(string[] args)
{
httpwebrequest request =
(httpwebrequest)webrequest.create("http://www.baidu.com");
//异步请求
iasyncresult asyncresult = request.begingetresponse(requestcompleted, request);
console.writeline("任务开始");
console.read();
}
}