using System.Threading.Tasks;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal abstract class QueryBaseNode<T> : IVisitableNode
{
using System.Threading.Tasks;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QueryCastNode<T> : QueryStreamNode<object, T>
{
#if NET_4_0
using System;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal abstract class QueryChildNode<T, TParent> : QueryBaseNode<T>
{
using System.Collections;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QueryConcatNode<TSource> : QueryMuxNode<TSource, TSource, TSource>
{
using System.Collections;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QueryDefaultEmptyNode<TSource> : QueryStreamNode<TSource, TSource>
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QueryGroupByNode<TSource, TKey, TElement> : QueryStreamNode<IGrouping<TKey, TElement>, TSource>
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal abstract class QueryMuxNode<TFirst, TSecond, TResult> : QueryChildNode<TResult, TFirst>
{
using System.Threading;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
// The first four elements correspond to the public operator With*
// Last CancellationToken parameter is used internally for ImplementerToken
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QueryOrderByNode<T> : QueryOrderGuardNode<T>
{
using System;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal abstract class QueryOrderGuardNode<T> : QueryStreamNode<T, T>
{
#if NET_4_0
using System;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal abstract class QueryOrderedStreamNode<T, TParent> : QueryStreamNode<T, TParent>
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QueryReverseNode<TSource> : QueryStreamNode<TSource, TSource>
{
using System.Collections;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QuerySelectManyNode<TSource, TCollection, TResult> : QueryStreamNode<TResult, TSource>
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QuerySelectNode<TResult, TSource> : QueryStreamNode<TResult, TSource>
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QuerySetNode<TSource> : QueryMuxNode<TSource, TSource, TSource>
{
using System.Threading;
using System.Threading.Tasks;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QueryStartNode<T> : QueryBaseNode<T>
{
using System.Threading.Tasks;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal abstract class QueryStreamNode<T, TParent> : QueryChildNode<T, TParent>
{
using System.Threading;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QueryWhereNode<TSource> : QueryStreamNode<TSource, TSource>
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class QueryZipNode<TFirst, TSecond, TResult> : QueryMuxNode<TFirst, TSecond, TResult>
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
[Flags]
internal enum SetInclusion {
using System.Collections;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel.QueryNodes
{
internal class WrapHelper
{
using System.Collections;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class AggregationList<T> : IList<T>
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class ConcurrentGrouping<TKey, TElement> : IGrouping<TKey, TElement>
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class ConcurrentLookup<TKey, TElement> : ILookup<TKey, TElement>
{
#if NET_4_0
using System;
+using System.Linq.Parallel.QueryNodes;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal interface INodeVisitor
{
#if NET_4_0
using System;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal interface IVisitableNode
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class OrderingEnumerator<T> : IEnumerator<T>
{
using System.Collections;
using System.Collections.Generic;
using System.Collections.Concurrent;
+using System.Linq.Parallel.QueryNodes;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal static class ParallelExecuter
{
#if NET_4_0
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal static class ParallelPartitioner
{
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
+#if NET_4_0
using System;
using System.Threading;
using System.Collections;
using System.Collections.Generic;
using System.Collections.Concurrent;
+using System.Linq.Parallel.QueryNodes;
-#if NET_4_0
-
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class ParallelQueryEnumerator<T> : IEnumerator<T>
{
using System.Threading.Tasks;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel
{
// HACK: ATM: parallelization of the sort is disabled as task
// add more overhead than gain
#if NET_4_0
using System;
using System.Threading;
+using System.Linq.Parallel.QueryNodes;
-namespace System.Linq
+namespace System.Linq.Parallel
{
using OptionsList = Tuple<ParallelMergeOptions?, ParallelExecutionMode?, CancellationToken?, int, CancellationTokenSource>;
using System;
using System.Threading;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class QueryOptions
{
using System.Collections;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class RangeList : IList<int>
{
using System.Collections;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class RepeatList<T> : IList<T>
{
using System.Collections;
using System.Collections.Generic;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class ReverseList<T> : IList<T>
{
using System.Collections.Generic;
using System.Collections.Concurrent;
-namespace System.Linq
+namespace System.Linq.Parallel
{
internal class StripPartitioner<T> : OrderablePartitioner<T>
{
using System.Collections;
using System.Collections.Generic;
using System.Collections.Concurrent;
+using System.Linq.Parallel.QueryNodes;
namespace System.Linq
{
using System.Collections;
using System.Collections.Generic;
using System.Collections.Concurrent;
+using System.Linq.Parallel;
+using System.Linq.Parallel.QueryNodes;
namespace System.Linq
{
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
+#if NET_4_0
+
using System;
using System.Threading;
using System.Collections;
using System.Collections.Generic;
using System.Collections.Concurrent;
-
-#if NET_4_0
+using System.Linq.Parallel;
+using System.Linq.Parallel.QueryNodes;
namespace System.Linq
{