ParallelForEach<T> Klass

Definition

generic <typename T>
public ref class ParallelForEach sealed : System::Activities::NativeActivity

[System.Windows.Markup.ContentProperty("Body")]
public sealed class ParallelForEach<T> : System.Activities.NativeActivity

[<System.Windows.Markup.ContentProperty("Body")>]
type ParallelForEach<'T> = class
    inherit NativeActivity

Public NotInheritable Class ParallelForEach(Of T)
Inherits NativeActivity

Typparametrar

Arv

Object

Activity

NativeActivity

ParallelForEach<T>

Attribut

ContentPropertyAttribute

Exempel

Följande kodexempel visar hur du skapar en ParallelForEach<T> aktivitet. Det här exemplet kommer från exemplet för företagsprocessen .

// invite all vendors and wait for their proposals
new ParallelForEach<Vendor>
{
    DisplayName = "Get vendor proposals",
    Values = new InArgument<IEnumerable<Vendor>>(ctx =>this.Rfp.Get(ctx).InvitedVendors),
    Body = new ActivityAction<Vendor>()
    {
        Argument = iterationVariableVendor,
        Handler = new Sequence
        {
            Variables = { tmpValue },
            Activities =
            {
                // waits for a vendor proposal (creates a bookmark for a vendor)
                new WaitForVendorProposal
                {
                    VendorId = new LambdaValue<int>(ctx =>iterationVariableVendor.Get(ctx).Id) ,
                    Result = new OutArgument<double>(tmpValue)
                },

                // after the vendor proposal is received, it is registered in the Request for Proposals
                new InvokeMethod
                {
                    TargetObject = new InArgument<RequestForProposal>(ctx =>this.Rfp.Get(ctx)),
                    MethodName = "RegisterProposal",
                    Parameters =
                    {
                        new InArgument<Vendor>(iterationVariableVendor),
                        new InArgument<double>(tmpValue)
                    }
                },
            }
        }
    }
},

Kommentarer

Inbäddade instruktioner schemaläggs tillsammans och körs asynkront, men om inte de schemalagda aktiviteterna själva är asynkrona (till exempel meddelandeaktiviteter, InvokeMethodeller aktiviteter som härleds från AsyncCodeActivity) körs de inte på separata trådar, så varje efterföljande aktivitet körs bara när den tidigare schemalagda aktiviteten slutförs eller inaktiv. Om ingen av de underordnade aktiviteterna i den här aktiviteten är asynkrona eller inaktiva körs den här aktiviteten på samma sätt som en ForEach<T> aktivitet gör.