如何解决如何在 C# 控制台应用程序中自动强制停止当前线程
大家好,我是多线程编码的新手,我的任务是更改当前工作的控制台应用程序的流程。当前,当控制台应用程序启动时,它会通过以下代码。 “Task.Factory.Startnew”方法启动新线程并运行“CheckDatabaseFieldStatus”,它正在检查数据库表字段的状态。如果此字段具有“取消”值,则它将调用 Token.cancel() 方法。
与此同时,当前线程正在执行某种逻辑并不断调用“CheckCancelTokenStatus”函数以抛出“ThrowIfCancellationRequested”异常。
新要求:我想从“Task.Factory.Startnew”方法创建的另一个线程中停止当前线程。如何以安全的方式从另一个线程中强制取消当前线程?
代码如下:
public CancellationTokenSource TokenSource = new CancellationTokenSource();
public CancellationToken Token = TokenSource.Token;
try
{
// Spin up a task that will keep checking the request to see if it has been cancelled.
Task cancelCheck = Task.Factory.StartNew(CheckDatabaseFieldStatus,TaskCreationoptions.LongRunning);
//Some logic to finish task
CheckCancelTokenStatus(Token);
//Some logic to finish task
CheckCancelTokenStatus(Token);
//Some logic to finish task
CheckCancelTokenStatus(Token);
//Some logic to finish task
}
catch (OperationCanceledException){
//Database call to Update status of task to canceled
}
//here is dispose method dispose token
这是函数“CheckDatabaseFieldStatus”
public void CheckDatabaseFieldStatus()
{
// While a Request is running,we're going to keep polling to check if we want to cancel.
while (!Token.IsCancellationRequested)
{
// Using the request timer here for our wait would mean that requests Could take up to 30
seconds to finish after they've actually finished.
Thread.Sleep(5000);
// Create a new context with each check to avoid conflicts with main context
using (DbContext mydb= new DbContext())
{
// Get the newest version of the request and check if it's set to cancel.
if (mydb.Table.GetAll().Any(r => r.Status=="cancelling"))
{
TokenSource.Cancel();
}
}
}
}
这里是函数 CheckCancelTokenStatus
function CheckCancelTokenStatus(CancellationToken Token)
{
if (Token.HasValue && Token.Value.IsCancellationRequested)
{
Token.Value.ThrowIfCancellationRequested();
}
}
解决方法
不要使用 Thread.Sleep
尝试使用 Task.Delay(int milliseconds,CancellationToken token)
。 Task.Delay 创建将在给定延迟后完成的任务。如果令牌在等待期间被取消,它将抛出异常并停止执行。最好在等待取消之前和之后进行检查,因为有人可能会在您睡觉时取消执行。
public void CheckDatabaseFieldStatus()
{
while (!Token.IsCancellationRequested)
{
Task.Delay(5000,Token).GetAwaiter().GetResult();
Token.ThrowIfCancellationRequested();
using (DbContext mydb= new DbContext())
{
if (mydb.Table.GetAll().Any(r => r.Status=="cancelling"))
{
TokenSource.Cancel();
}
}
}
}
此外,我使用 GetAwaiter().GetResult()
而不是简单的 Wait()
因为第二个选项包装异常。请参阅此答案以获取解释https://stackoverflow.com/a/38530225/10339675
一般来说最好使用 async
/await
而不是同步等待
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。