1

如何用 ParallelEnumerable.AsParallel 包装 NewArrayExpression ？

例如我有代表下一个代码的表达式：

var data = new int {1, 2, 3, 4, 5};

我想要得到的结果：

var data = new int {1, 2, 3, 4, 5}.AsParallel();

我尝试使用 ExpressionVisitor 和 VisitNewArray 方法：

    protected override Expression VisitNewArray(NewArrayExpression node)
    {

            var source = Expression.Parameter(typeof(IEnumerable<>).MakeGenericType(typeof(MethodCallExpression)), "source");

            var asParallel =
                Expression.Call(
                    typeof(ParallelEnumerable),
                    nameof(ParallelEnumerable.AsParallel),
                    new[] { typeof(ParallelQuery<MethodCallExpression>) },
                    source
                );

            return ***???***
    }

但不知道如何正确“包装” node.Expressions这个Expression.Call

感谢您的任何建议！

4

1 回答 1

2

这样做会将表达式类型更改为T[]可能ParallelQuery<T>导致问题的形式。

但回答你的具体问题。让我们重写你的例子

var data = new int[] {1, 2, 3, 4, 5}.AsParallel();

如下

var newArray = new int[] { 1, 2, 3, 4, 5 };
var data = newArray.AsParallel();

现在考虑到这AsParallel是通用静态扩展方法，删除编译器糖后的实际调用是

var data = ParallelEnumerable.AsParallel<int>(newArray);

换句话说，调用泛型静态方法传递数组元素类型作为泛型类型参数和new数组表达式作为参数。例如

protected override Expression VisitNewArray(NewArrayExpression node)
{
    var asParallel = Expression.Call(
        typeof(ParallelEnumerable),
        nameof(ParallelEnumerable.AsParallel),
        new [] { node.Type.GetElementType() },
        node
    );
    return asParallel;
}
于 2019-11-28T20:43:04.500 回答