81 lines
1.6 KiB
C#
81 lines
1.6 KiB
C#
namespace CloudGaming.Core.Processors;
|
|
|
|
/// <summary>
|
|
/// 包含处理线程的处理器基类
|
|
/// </summary>
|
|
public abstract class ThreadProcessor : BaseProcessor
|
|
{
|
|
protected Thread? _thread;
|
|
protected bool _isRunning;
|
|
protected string? _threadName;
|
|
|
|
/// <summary>
|
|
/// 构造函数
|
|
/// </summary>
|
|
public ThreadProcessor() { }
|
|
|
|
/// <summary>
|
|
/// 构造函数
|
|
/// </summary>
|
|
/// <param name="threadName">线程名称</param>
|
|
public ThreadProcessor(string threadName)
|
|
{
|
|
_threadName = threadName;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 执行处理
|
|
/// </summary>
|
|
/// <exception cref="InvalidOperationException">如果处理器已经在运行，抛出异常</exception>
|
|
public override void Run()
|
|
{
|
|
if (_isRunning)
|
|
{
|
|
throw new InvalidOperationException("重复执行线程");
|
|
}
|
|
|
|
_isRunning = true;
|
|
|
|
_thread = new Thread(Proc_Do)
|
|
{
|
|
Name = _threadName
|
|
};
|
|
_thread.Start();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 线程处理函数，需要在子类中实现
|
|
/// </summary>
|
|
protected abstract void Proc_Do();
|
|
|
|
/// <summary>
|
|
/// 停止处理线程
|
|
/// </summary>
|
|
public override void Stop()
|
|
{
|
|
if (!_isRunning)
|
|
{
|
|
return;
|
|
}
|
|
|
|
_isRunning = false;
|
|
|
|
if (_thread != null && _thread.IsAlive)
|
|
{
|
|
_thread.Join(WaitTimeMax_StopProc); // 等待线程结束
|
|
_thread = null;
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 释放资源
|
|
/// </summary>
|
|
public override void Dispose()
|
|
{
|
|
Stop();
|
|
base.Dispose();
|
|
}
|
|
|
|
|
|
}
|