C# 获取异步任务

Question

一旦退出最初启动任务的方法，有没有办法通过 ID 获取当前正在运行的任务？我想以某种方式获取当前任务，这样我就可以在执行过程中停止其中一些任务，而不会中断程序的流程。

例如：

class Test
{
    List<Task> listOfTasks = new List<Task>();


    void taskCaller()
    {
        try
        {
            var myTask = Task.Factory.StartNew(()=> testMethod());
            listOfTasks.Add(myTask);
        }
        catch (System.Exception)
        {
            //...
            throw;
        }
    }


    void taskGetter()
    {
        foreach (var item in listOfTasks)
        {
            if(item == something)
            {
                item.KillExecution();
            }
        }
    }


    private void testMethod()
    {
        // doing something
        throw new NotImplementedException();
    }
}

编辑

如果可能的话，我希望它在没有取消令牌的情况下完成，因为它不适合我，因为我正在运行一个从数据库获取 DLL 的计时器，并且取消令牌只有在我立即使用 token.Cancel() 终止任务时才有效但是，如果我尝试token.CancelAfter() 它不起作用，因为它仅在任务完成执行后才会触发，这不是想法。

EDIT2：

不要复制大量代码，这是整个流程的伪代码：

new timer(repeat method every xx time units)
    open DB
    do some work
    save DB

继续plast1k 建议...

如果在这种情况下请求取消，当我检查字典时，它会显示 true，但它对正在运行的任务没有任何作用

private void getActiveTasks()
{
    if (!ListOfTasks.Any())
        return;
    Console.WriteLine("Currently running:");
    foreach (var task in ListOfTasks)
    {
        Console.WriteLine("\t" + task.Key);
        Console.WriteLine("\t" + task.Value.MyTask.Id);
        task.Value.Token.Cancel();
        Console.WriteLine("\t" + task.Value.Token.IsCancellationRequested);


        ListOfTasks.Remove(task.Key);
        return;
    }
}

Answer 1

正如您可能已经研究过的那样，到目前为止，取消任务的唯一方法是使用取消令牌让它知道取消并使其知道取消。此外，这也是执行此操作的首选方法。但是，由于您的问题提到您不能使用取消源，您可以使用另一个 SO 答案中提到的技术（包括链接）。

链接中的要点，您可以创建这些任务并在不同的线程上运行它们，并在您可能想要取消任务时中止线程

How do I force a Task to stop?

Answer 2

确保您实际上是在任务内部处理取消（通过 cancelToken.ThrowIfCancellationRequested() ），因为在令牌源上调用 Cancel 只会取消任务调度，它实际上并没有停止执行。 p>

停止任务的正确方法是使用取消标记。 在此处查看示例

https://msdn.microsoft.com/en-us/library/dd997396(v=vs.110).aspx

这里

https://blogs.msdn.microsoft.com/andrewarnottms/2014/03/19/recommended-patterns-for-cancellationtoken/

Answer 3

虽然您应该看到 usaipavan 的答案和链接以了解正确的取消技术，但为了跟踪您的线程或任务，您只需将它们添加到字典而不是列表并分配您选择的 ID。它可以是一个整数或一个字符串或任何东西，在这个例子中它是一个 GUID。

Dictionary<Guid, Task> listofTasks = new Dictionary<Guid, Task>();

public Guid StartTask()
{
    Task myTask = Task.Factory.StartNew(()=> testMethod());
    Guid taskID = Guid.NewGuid();
    listOfTasks.Add(taskID, myTask);
    return taskID;
}

public void CancelTask(Guid id)
{
    // listOfTasks[id].choose_your_own_task_cancellation_adventure()
}

如果您可以使用取消标记，您可以将它们存储在字典/另一个字典/作为元组中。如果您想识别这些任务的组（即，取消对“数据库查询”操作的所有请求），您可以执行以下操作

public class TaskWrapper
{
    public TaskWrapper(string operationID, Task task, CancellationTokenSource cancellationSource)
    {
        this.OperationID = operationID;
        this.Task = task;
        this.CancellationSource = cancellationSource;
    }
    public string OperationID { get; set; }
    public Task Task { get; set; }
    public CancellationTokenSource CancellationSource { get; set; }
}


private Dictionary<Guid, TaskWrapper> ListOfTasks = new Dictionary<Guid, TaskWrapper>();


// populate the list


public void CancelAll(string operation)
{
    listOfTasks.Where(a => a.OperationID == operation).CancellationSource.Cancel();
}