lsm/Orchard
1
0
Fork 0
mirror of https://github.com/OrchardCMS/Orchard.git synced 2026-02-09 09:16:41 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Allow disabling parallel behavior through HostComponents.config

Browse Source 
Safety net...

--HG--
branch : 1.x
This commit is contained in:
Renaud Paquay
2011-06-02 17:23:14 -07:00
parent 1d5fd306b9
commit c20d722ee9
1 changed files with 24 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/Orchard/Caching/DefaultParallelCacheContext.cs
View File

@@ -10,22 +10,32 @@ namespace Orchard.Caching {
_cacheContextAccessor = cacheContextAccessor;
}
/// <summary>
/// Allow disabling parallel behavior through HostComponents.config
/// </summary>
public bool Disabled { get; set; }
public IEnumerable<TResult> RunInParallel<T, TResult>(IEnumerable<T> source, Func<T, TResult> selector) {
// Create tasks that capture the current thread context
var tasks = source.Select(item => this.CreateContextAwareTask(() => selector(item))).ToList();
// Run tasks in parallel and combine results immediately
var result = tasks
.AsParallel() // prepare for parallel execution
.AsOrdered() // preserve initial enumeration order
.Select(task => task.Execute()) // prepare tasks to run in parallel
.ToArray(); // force evaluation
// Forward tokens collected by tasks to the current context
foreach (var task in tasks) {
task.Finish();
if (Disabled) {
return source.Select(selector);
}
else {
// Create tasks that capture the current thread context
var tasks = source.Select(item => this.CreateContextAwareTask(() => selector(item))).ToList();
// Run tasks in parallel and combine results immediately
var result = tasks
.AsParallel() // prepare for parallel execution
.AsOrdered() // preserve initial enumeration order
.Select(task => task.Execute()) // prepare tasks to run in parallel
.ToArray(); // force evaluation
// Forward tokens collected by tasks to the current context
foreach (var task in tasks) {
task.Finish();
}
return result;
}
return result;
}
/// <summary>