2

我正在尝试使用 TPL 执行一些过滤任务。在这里，我正在简化代码以根据条件过滤数字。这是代码。

public static void Main (string[] args)
    {
        IEnumerable<int> allData = getIntData ();

        Console.WriteLine ("Complete Data display");
        foreach (var item in allData) {
            Console.Write(item);
            Console.Write(" | ");
        }

        Console.WriteLine ();
        filterAllDatas (ref allData, getConditions ());

        foreach (var item in allData) {
            Console.Write(item);
            Console.Write(" | ");
        }
        Console.WriteLine ();
    }

    static void filterAllDatas(ref IEnumerable<int> data, IEnumerable<Func<int,bool>> conditions)
    {
        List<int> filteredData = data.ToList ();
        List<Task> tasks = new List<Task>();
        foreach (var item in data.AsParallel()) {
            foreach (var condition in conditions.AsParallel()) {

                tasks.Add(Task.Factory.StartNew(() => {
                    if (condition(item)) {
                        filteredData.Remove(item);
                    }
                }));

            }
        }
        Task.WaitAll(tasks.ToArray());
        data = filteredData.AsEnumerable ();
    }
    static IEnumerable<Func<int,bool>> getConditions()
    {
        yield return (a) => { Console.WriteLine("modulo by 2"); return a % 2 == 0;};
        yield return (a) => { Console.WriteLine("modulo by 3"); Thread.Sleep(3000); return a % 3 == 0;};

    }
    static IEnumerable<int> getIntData ()
    {
        for (int i = 0; i < 10; i++) {
            yield return i;
        }
    }

在这里，过滤掉除以二或三的整数是简单的代码。现在，如果我删除该线程睡眠代码可以完美地工作，但如果我说它不是。

通常意味着没有 Thread.Sleep ，两个条件都执行 10 次，例如每个数字。但如果我添加 Thread.Sleep 第一个条件执行 7 次，第二个条件执行 13 次。并且由于这几个数字跳过了条件。我尝试调试但没有得到任何可以指出我的代码问题的东西。

有什么好的方法可以实现这一目标吗？像数据上的过滤条件可以异步和并行工作以提高性能吗？

代码仅用于演示目的。

仅供参考：目前我在 Windows 机器上使用 Mono 和 Xamarine studio。

如果需要任何进一步的细节，请告诉我。

4

2 回答 2

2

我猜这与你的任务的 lambda 如何关闭循环变量有关condition。尝试如下更改：

        foreach (var condition in conditions.AsParallel()) {
            var tasksCondition = condition
            tasks.Add(Task.Factory.StartNew(() => {
                if (tasksCondition(item)) {
                    filteredData.Remove(item);
                }
            }));

请注意，您还关闭了循环变量item，这可能会导致类似的问题。

于 2013-03-15T13:18:21.007 回答
1

首先，您可以更改 getConditions 方法以查看内部发生的情况：

static IEnumerable<Func<int, bool>> getConditions()
{
    yield return (a) => { Console.WriteLine(a + " modulo by 2"); return a % 2 == 0; };
    yield return (a) => { Console.WriteLine(a + " modulo by 3"); Thread.Sleep(3000); return a % 3 == 0; };
}

如果您停止捕获 foreach 的变量，它将起作用：

static void filterAllDatas(ref IEnumerable<int> data, IEnumerable<Func<int, bool>> conditions)
{
    List<int> filteredData = data.ToList();
    List<Task> tasks = new List<Task>();
    foreach (var item in data.AsParallel())
    {
        var i = item;
        foreach (var condition in conditions.AsParallel())
        {
            var c = condition;
            tasks.Add(Task.Factory.StartNew(() =>
            {
                if (c(i))
                {
                    filteredData.Remove(i);
                }
            }));

        }
    }
    Task.WaitAll(tasks.ToArray());
    data = filteredData.AsEnumerable();
}
于 2013-03-15T13:27:40.400 回答