『C#基础』多线程笔记「一」基本说明

带回调的被操作类using System;
using System.Threading;

namespace csdemo.basic.ThreadsDemo
{
public class WorkerClass
{
#region 属性
public string WorkerName = "No One";
public string WorkName = "not working";
public int Times = 10000;

ExampleCallback callback;

// 用于控制线程的停止
private bool _threadStop = false;
// 用于控制另一个线程的Join操作
private bool isOtherJoined = false;
private Thread otherThread = null;
#endregion
#region 构造函数

public WorkerClass()
{
this.WorkerName = "No One";
this.WorkName = "not working";
this.Times = 10000;
}

public WorkerClass(string workerName,string workName,int times,ExampleCallback callbackDelegate)
{
this.WorkerName = workerName;
this.WorkName = workName;
// 回调方法的委托
this.callback = callbackDelegate;
}
#endregion

// 传入线程的方法
public void Do()
{
Console.WriteLine("Worker thread is started.");

for (int i = 1; i <= Times; i++)
{
if (_threadStop == true)
break;

if (isOtherJoined == true)
otherThread.Join();

// 回调方法，表面上看是调用一个委托
// 实质上返回的数据为当前的输出次数
if (callback != null)
callback(i);

// Console.WriteLine("{0} is {1} now!", WorkerName, WorkName);
Thread.Sleep(1000);
}

Console.WriteLine("Worker thread is complete.");
}

#region 其他操作
/// <summary>
/// 这个操作是用于停止线程调用的对象方法的分行；
/// 通过在实调用对象中，创建一个bool类型的变量来监视停止状态；
/// 在主线程中，通过设置辅助线程的监视变量的值来控制线程的停止行为；
/// 需要注意的是，这种方法只能够用于停止线程的执行，而无法让被停止的线程继续执行。
/// </summary>
internal void RequestStop()
{
Console.WriteLine("{0} Thread: Force stoped");
_threadStop = true;
}

/// <summary>
/// 强行执行一个线程，直到结束为止；
/// 这个操作会阻塞其他在当前里程中执行的线程，也就是说让当前进程中的其他线程都给这个线程让路；
///
/// 由于Thread是使用方法作为实例化方法的，所以还是要在操作类中加入一个bool类型的变量来控制另一个线程的Join操作；
/// </summary>
/// <param name="thread">要Join入当前线程的另一个线程对象</param>
internal void RequestJoin(Thread thread)
{
Console.WriteLine("{0} Thread: {1} joined!",this.WorkerName,thread.Name);
this.otherThread = thread;
isOtherJoined = true;
}
#endregion
}
}