@@ -16,15 +16,15 @@ public class DegreeOfParallelismTests
16
16
// If ThreadPool becomes available, uncomment the below
17
17
//private static ThreadPoolManager _poolManager = new ThreadPoolManager();
18
18
19
- public static IEnumerable < object [ ] > DegreeData ( object [ ] counts , object [ ] degrees )
19
+ public static IEnumerable < object [ ] > DegreeData ( int [ ] counts , int [ ] degrees )
20
20
{
21
21
foreach ( object [ ] results in UnorderedSources . Ranges ( counts . Cast < int > ( ) , x => degrees . Cast < int > ( ) . DefaultIfEmpty ( x ) ) )
22
22
{
23
23
yield return results ;
24
24
}
25
25
}
26
26
27
- public static IEnumerable < object [ ] > NotLoadBalancedDegreeData ( object [ ] counts , object [ ] degrees )
27
+ public static IEnumerable < object [ ] > NotLoadBalancedDegreeData ( int [ ] counts , int [ ] degrees )
28
28
{
29
29
foreach ( object [ ] results in DegreeData ( counts , degrees ) )
30
30
{
@@ -53,7 +53,7 @@ public static void DegreeOfParallelism(Labeled<ParallelQuery<int>> labeled, int
53
53
}
54
54
55
55
[ Theory ]
56
- [ MemberData ( "DegreeData" , new [ ] { 1 , 4 , 32 } , new object [ ] { } ) ]
56
+ [ MemberData ( "DegreeData" , new [ ] { 1 , 4 , 32 } , new int [ ] { } ) ]
57
57
[ OuterLoop ]
58
58
public static void DegreeOfParallelism_Barrier ( Labeled < ParallelQuery < int > > labeled , int count , int degree )
59
59
{
@@ -79,7 +79,7 @@ public static void DegreeOfParallelism_Pipelining(Labeled<ParallelQuery<int>> la
79
79
}
80
80
81
81
[ Theory ]
82
- [ MemberData ( "DegreeData" , new [ ] { 1 , 4 } , new object [ ] { } ) ]
82
+ [ MemberData ( "DegreeData" , new [ ] { 1 , 4 } , new int [ ] { } ) ]
83
83
[ MemberData ( "DegreeData" , new [ ] { 32 } , new [ ] { 4 } ) ]
84
84
// Without the ability to ask the thread pool to create a minimum number of threads ahead of time,
85
85
// higher thread counts take a prohibitive amount of time spooling them up.
@@ -100,7 +100,7 @@ public static void DegreeOfParallelism_Throttled_Pipelining(Labeled<ParallelQuer
100
100
}
101
101
102
102
[ Theory ]
103
- [ MemberData ( "NotLoadBalancedDegreeData" , new [ ] { 1 , 4 } , new object [ ] { } ) ]
103
+ [ MemberData ( "NotLoadBalancedDegreeData" , new [ ] { 1 , 4 } , new int [ ] { } ) ]
104
104
[ MemberData ( "NotLoadBalancedDegreeData" , new [ ] { 32 , 512 , 1024 } , new [ ] { 4 , 16 } ) ]
105
105
[ OuterLoop ]
106
106
public static void DegreeOfParallelism_Aggregate_Accumulator ( Labeled < ParallelQuery < int > > labeled , int count , int degree )
@@ -118,7 +118,7 @@ public static void DegreeOfParallelism_Aggregate_Accumulator(Labeled<ParallelQue
118
118
}
119
119
120
120
[ Theory ]
121
- [ MemberData ( "NotLoadBalancedDegreeData" , new [ ] { 1 , 4 } , new object [ ] { } ) ]
121
+ [ MemberData ( "NotLoadBalancedDegreeData" , new [ ] { 1 , 4 } , new int [ ] { } ) ]
122
122
[ MemberData ( "NotLoadBalancedDegreeData" , new [ ] { 32 , 512 , 1024 } , new [ ] { 4 , 16 } ) ]
123
123
[ OuterLoop ]
124
124
public static void DegreeOfParallelism_Aggregate_SeedFunction ( Labeled < ParallelQuery < int > > labeled , int count , int degree )
0 commit comments