我目前正在编写一个服务,它将为他在数据库中找到的每个“等待进程”请求创建Task。使用Task.WhenAny与字典
该过程可能很长,并且我希望服务在每次必须取消任务时检查它,如果是这种情况我想用令牌取消任务。所以我需要存储链接到任务的请求的ID。
我在想,我有我的字典静态类如下:
public static Dictionary<Int32, Task<Int32>> _tasks = new Dictionary<int, Task<int>>();
,我不知道这是否是更好的解决方案存在,但它仍然是一个工作,我认为。
现在我想做一个Task.WhenAny(..)来知道其中一个是否结束。问题是Task.WhenAny(..)接受一个数组,但不是一个Dictionary。我没有看到任何关于将字典传递给WhenAny的任何事情,并且在开始处理很长的整个过程之前,我希望为我的工作流程的每个关键点提供解决方案。我可以获得字典值的列表,但我可能会丢失id链接。所以我不知道该怎么办?
有没有解决方案?我不想重新创建自己的“自己的”WhenAny,我甚至不知道是否有可能,但我认为我只能解析每一行的状态。但如果这是唯一的选择,我会的。
我也打开这样一个事实,即以这种方式存储请求的ID不是一个好办法,在这种情况下,我可以接受任何其他建议。
编辑:CODE ACORDING进行答辩 我使用此代码,这似乎是工作结束。现在我将测试更复杂的任务,而不仅仅是一个文件写入! :)
public static class Worker
{
public static List<Task<Int32>> m_tasks = new List<Task<Int32>>();
public static Dictionary<Int32, CancellationTokenSource> m_cancellationTokenSources = new Dictionary<int, CancellationTokenSource>();
public static Int32 _testId = 1;
public static void run()
{
//Clean
Cleaner.CleanUploads();
Cleaner.CleanDownloads();
#region thread watching
if (m_tasks.Count > 0)
{
#region thread must be cancel
//Cancel thread
List<Task<Int32>> _removeTemp = new List<Task<Int32>>();
foreach (Task<Int32> _task in m_tasks)
{
if (DbWorker.mustBeCancel((Int32)_task.AsyncState))
{
m_cancellationTokenSources[(Int32)_task.AsyncState].Cancel();
//Cancellation actions
//task must be remove
_removeTemp.Add(_task);
}
}
foreach(Task<Int32> _taskToRemove in _removeTemp)
{
m_tasks.Remove(_taskToRemove);
}
#endregion
#region Conversion lookup
// Get conversion if any
// Create task
CancellationTokenSource _srcCancel = new CancellationTokenSource();
m_cancellationTokenSources.Add(_testId, _srcCancel);
m_tasks.Add(Task.Factory.StartNew(_testId => testRunner<Int32>((Int32)_testId), _testId, _srcCancel.Token));
_testId++;
// Attach task
#endregion
}
#endregion
else
{
CancellationTokenSource _srcCancel = new CancellationTokenSource();
m_cancellationTokenSources.Add(_testId, _srcCancel);
m_tasks.Add(Task.Factory.StartNew(_testId => testRunner<Int32>((Int32)_testId), _testId, _srcCancel.Token));
_testId++;
}
}
internal static void WaitAll()
{
Task.WaitAll(m_tasks.ToArray());
}
public static Int32 testRunner<T>(T _id)
{
for (Int32 i = 0; i <= 1000000; i++)
{
File.AppendAllText(@"C:\TestTemp\" + _id, i.ToString());
}
return 2;
}
}
使用我会回来结束的任务,但我会失去在我的字典中用作键的id吧? :/ –
@GrégoryLyes;所以你要么需要重新找到它,要么使用任务上的'AsyncState' –
我刚刚搜索了一下asyncState,所以如果我的理解很好,我可以找回我作为参数传递给任务的ID ?在这种情况下,我不再需要字典了,因为我可以将ID退回。 –