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(객체 상태)로 정의됩니다.

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의 One 매개 변수는 지정된 시간 내에 대기하는 시간(밀리초)을 나타냅니다. 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. 콜백 메소드를 사용하여 결과를 반환합니다

BeginInvoke 메소드의 매개변수 전달 메소드인 "my.BeginInvoke(3,300, MethodCompleted, my)"에 유의하세요. :

첫 번째 부분(3,300)은 해당 대리자 자체의 매개변수입니다.

두 번째 매개 변수(MethodCompleted)는 콜백 메서드 대리자 유형입니다. 이 대리자는 반환 값이 없으며 메서드 메서드가 실행될 때 시스템에서 발생합니다. 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 메서드

System.Net의 BeginGetResponse 및 EndGetResponse와 같은 다른 .net 구성 요소에도 BeginInvoke 및 EndInvoke와 유사한 메서드가 있습니다. HttpWebRequest 클래스 메서드. 사용법은 대리자 유형의 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();
}
}