GetPartitions 得到了偏斜的分区?
GetPartitions got skewed partitions?
运行 C# 交互中的以下代码window
using System.Collections.Concurrent;
var l = Enumerable.Range(0, 20);
Partitioner.Create(l).GetPartitions(4)
.Select(x => {
var s = "";
while (x.MoveNext()) { s += x.Current.ToString() + ","; };
return s;
})
returns
Enumerable.WhereSelectArrayIterator<IEnumerator<int>, string>
{ "0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,", "", "", "" }
好像一个分区得到了所有的值?我尝试了大尺寸 Enumerable.Range(0, 12000)
,所有元素仍然在第一个分区中。
我想确保以下扩展方法可以均匀地划分列表。
public static Task ForEachAsync<T>(this IEnumerable<T> source, int dop, Func<T, Task> body)
{
return Task.WhenAll(
from partition in Partitioner.Create(source).GetPartitions(dop)
select Task.Run(async delegate {
using (partition)
while (partition.MoveNext())
await body(partition.Current);
}));
}
我会说是您的代码导致了它:您只枚举了一个分区,但根据要求这些分区是 "filled"。
你想要一个简单的测试?
Partitioner.Create(l).GetPartitions(4)
.Skip(1)
.Select(x => {
var s = "";
while (x.MoveNext()) { s += x.Current.ToString() + ","; };
return s;
})
现在是另一个分区获取了所有值:-) 但是不是第一个分区获取了所有值吗?现在是第二个:-)
更正确的测试是:
var l = Enumerable.Range(0, 20);
var parts = Partitioner.Create(l).GetPartitions(4);
string[] bufs = new string[parts.Count];
while (true)
{
int countFinished = 0;
for (int i = 0; i < parts.Count; i++)
{
if (parts[i].MoveNext())
{
bufs[i] += parts[i].Current + ",";
}
else
{
countFinished++;
}
}
if (countFinished == parts.Count)
{
break;
}
}
for (int i = 0; i < parts.Count; i++)
{
Console.WriteLine(bufs[i]);
}
我正在同时枚举四个分区。这将在分区之间平均分配所有数字。
运行 C# 交互中的以下代码window
using System.Collections.Concurrent;
var l = Enumerable.Range(0, 20);
Partitioner.Create(l).GetPartitions(4)
.Select(x => {
var s = "";
while (x.MoveNext()) { s += x.Current.ToString() + ","; };
return s;
})
returns
Enumerable.WhereSelectArrayIterator<IEnumerator<int>, string>
{ "0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,", "", "", "" }
好像一个分区得到了所有的值?我尝试了大尺寸 Enumerable.Range(0, 12000)
,所有元素仍然在第一个分区中。
我想确保以下扩展方法可以均匀地划分列表。
public static Task ForEachAsync<T>(this IEnumerable<T> source, int dop, Func<T, Task> body)
{
return Task.WhenAll(
from partition in Partitioner.Create(source).GetPartitions(dop)
select Task.Run(async delegate {
using (partition)
while (partition.MoveNext())
await body(partition.Current);
}));
}
我会说是您的代码导致了它:您只枚举了一个分区,但根据要求这些分区是 "filled"。
你想要一个简单的测试?
Partitioner.Create(l).GetPartitions(4)
.Skip(1)
.Select(x => {
var s = "";
while (x.MoveNext()) { s += x.Current.ToString() + ","; };
return s;
})
现在是另一个分区获取了所有值:-) 但是不是第一个分区获取了所有值吗?现在是第二个:-)
更正确的测试是:
var l = Enumerable.Range(0, 20);
var parts = Partitioner.Create(l).GetPartitions(4);
string[] bufs = new string[parts.Count];
while (true)
{
int countFinished = 0;
for (int i = 0; i < parts.Count; i++)
{
if (parts[i].MoveNext())
{
bufs[i] += parts[i].Current + ",";
}
else
{
countFinished++;
}
}
if (countFinished == parts.Count)
{
break;
}
}
for (int i = 0; i < parts.Count; i++)
{
Console.WriteLine(bufs[i]);
}
我正在同时枚举四个分区。这将在分区之间平均分配所有数字。