我相信我可能只是语法错误,但我试图做的是创建一个在另一个任务完成后运行的任务。
我有一个列表中每个 100 个数组的任务。它启动一个新线程,将该数组传递到方法中。该方法完成后返回字典。我正在尝试创建一个任务以在方法完成后运行,它将返回的字典传递给执行更多工作的单独方法。
static void Main(string[] args)
{
try
{
stopwatch = new Stopwatch();
stopwatch.Start();
while (true)
{
startDownload();
}
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
}
public static async void startDownload()
{
try
{
DateTime currentDay = DateTime.Now;
if (Helper.holidays.Contains(currentDay) == false)
{
List<string> markets = new List<string>() { "amex", "global", "nasdaq", "nyse" };
Parallel.ForEach(markets, async market =>
{
try
{
IEnumerable<string> symbolList = Helper.getStockSymbols(market);
var historicalGroups = symbolList.Select((x, i) => new { x, i })
.GroupBy(x => x.i / 100)
.Select(g => g.Select(x => x.x).ToArray());
Task<Dictionary<string, string>>[] historicalTasks =
historicalGroups.Select(x => Task.Run(() =>
Downloads.getHistoricalStockData(x, market)))
.ToArray();
Dictionary<string, string>[] historcalStockResults = await
Task.WhenAll(historicalTasks);
foreach (var dictionary in historcalStockResults)
{
Downloads.updateSymbolsInDB(dictionary);
}
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
});
await Task.Delay(TimeSpan.FromHours(24));
}
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
}
如果您已经在使用await
,我建议您根本不使用ContinueWith
。原因是您最终在代码中得到的冗长。
相反,请尽可能使用await
。代码的结尾是这样的:
var historicalGroups = symbolList
.Select((x, i) => new { x, i })
.GroupBy(x => x.i / 100)
.Select(g => g.Select(x => x.x).ToArray());
var historicalTasks = historicalGroups.Select(x => Task.Run(() =>
Downloads.getHistoricalStockData(x, market)))
.ToArray();
var historcalStockResults = await Task.WhenAll(historicalTasks);
foreach (var dictionary in historcalStockResults)
{
Downloads.updateSymbolsInDB(dictionary);
}
请注意使用 Task.Run
而不是 Task.Factory.StartNew
。您应该改用它。更多关于这一点
编辑:
如果您需要每 24 小时执行一次此代码,请添加Task.Delay
并在其上await
:
await Task.Delay(TimeSpan.FromHours(24));
编辑 2:
你的代码不起作用的原因是startDownload
async void
,而你没有等待它。因此,无论您Task.Delay
如何,您的while
循环都会不断迭代。
由于你位于控制台应用程序内部,因此无法await
Main
因为方法不能异步。因此,要解决此问题,请将startDownload
更改为async Task
而不是async void
,并Wait
返回的Task
。请注意,几乎永远不应该使用Wait
,对于特殊情况(例如在控制台应用中运行时的情况),预期:
public async Task StartDownload()
然后
while (true)
{
StartDownload().Wait();
}
另请注意,混合Parallel.Foreach
和async-await
并不总是最好的主意。您可以在 Nesting await in Parallel.ForEach 中阅读更多相关信息
你会看到 ContinueWith 将 AS Task 作为参数。
此外,从我们评论中的逻辑来看,您似乎需要更新代码。 您正在尝试在所有WhenAll
任务的结果完成后运行一次Downloads.updateSymbolsInDB
。 在您的情况下,看起来您需要
await Task<Dictionary<string, string>>
.WhenAll(historicalGroups.Select(g => Task.Factory.StartNew(() => Downloads.getHistoricalStockData(g, market))))
.ContinueWith((i) => Downloads.updateSymbolsInDB(i.Result.Aggregate((agg, next) =>
{
foreach (var p in next)
{
if (!agg.ContainsKey(p.Key)) { agg.Add(p.Key, p.Value); }
}
return agg;
})));
请注意,我还使用 Task<TResult>
来启动,以便对ContinueWith
进行强类型以提供Dictionary<string, string>
i.Result
。
另请注意,您需要重新审视我在i.Result.Aggregate
逻辑中正在做的事情。 您需要更新它以适合您的情况。 此外,可能值得重新审视一下,看看多次调用Downloads.updateSymbolsInDB
是否更有效,或者Aggregate
调用是否是更好的选择。
(最后注意:最终结果是一个void
,所以没有分配等待。
在审查中,您的代码存在许多问题(意味着声明,而不是指控 - 无意冒犯)。 通过 Task.Factory.StartNew
为 WhenAll
方法创建的任务没有返回值,因此只是基本的Task
对象,实际上丢弃了Downloads.getHistoricalStockData
工作的结果。 然后,您的ContinueWith
需要使用WhenAll
的Task<TResult>
,其中TResult
将是WhenAll
内每个任务的返回值的数组。
编辑:正如被问及如果多次调用Downloads.updateSymbolsInDB
如何更新代码时,它可以简单地完成:
IEnumerable<string> symbolList = Helper.getStockSymbols(market);
var historicalGroups = symbolList.Select((x, i) => new { x, i })
.GroupBy(x => x.i / 100)
.Select(g => g.Select(x => x.x).ToArray());
Parallel.ForEach(historicalGroups, g => Downloads.updateSymbolsInDB(Downloads.getHistoricalStockData(g, market)));