MBrace.Core


IParallelismProvider

Namespace: MBrace.Core.Internals

MBrace dependency used for initiating parallel/distributed workflows.

Instance members

Instance memberDescription
CloudProcessId
Signature: string
Modifiers: abstract

Get cloud process identifier

CompiledName: get_CloudProcessId

CreateCancellationTokenSource(parents)
Signature: (parents:ICloudCancellationToken []) -> Async<ICloudCancellationTokenSource>
Modifiers: abstract

Creates a linked cancellation token source given collection of cloud cancellation tokens.

CurrentWorker
Signature: IWorkerRef
Modifiers: abstract

Gets currently running worker

CompiledName: get_CurrentWorker

FaultPolicy
Signature: FaultPolicy
Modifiers: abstract

Gets the current fault policy.

CompiledName: get_FaultPolicy

GetAvailableWorkers()
Signature: unit -> Async<IWorkerRef []>
Modifiers: abstract

Get all available workers in cluster

IsForcedLocalParallelismEnabled
Signature: bool
Modifiers: abstract

Specifies whether runtime will evaluate all parallelism primitives using threadpool semantics

CompiledName: get_IsForcedLocalParallelismEnabled

IsTargetedWorkerSupported
Signature: bool
Modifiers: abstract

Specifies whether runtime supports submission of tasks to specific worker nodes

CompiledName: get_IsTargetedWorkerSupported

Logger
Signature: ICloudLogger
Modifiers: abstract

Gets the current logger instance.

CompiledName: get_Logger

ScheduleChoice(computations)
Signature: (computations:seq<'a * IWorkerRef option>) -> Cloud<'T option>
Modifiers: abstract
Type parameters: 'a, 'T

Parallel nondeterministic choice implementation.

ScheduleCreateProcess(...)
Signature: (workflow:Cloud<'T> * faultPolicy:FaultPolicy * cancellationToken:ICloudCancellationToken option * target:IWorkerRef option * procName:string option) -> Cloud<ICloudProcess<'T>>
Modifiers: abstract
Type parameters: 'T

Start a new computation as a cloud process.

ScheduleLocalChoice(computations)
Signature: (computations:seq<LocalCloud<'T option>>) -> LocalCloud<'T option>
Modifiers: abstract
Type parameters: 'T

Parallel nondeterministic choice implementation.

ScheduleLocalParallel(computations)
Signature: computations:seq<LocalCloud<'T>> -> LocalCloud<'T []>
Modifiers: abstract
Type parameters: 'T

Parallel fork/join implementation.

ScheduleParallel(computations)
Signature: (computations:seq<'a * IWorkerRef option>) -> Cloud<'T []>
Modifiers: abstract
Type parameters: 'a, 'T

Parallel fork/join implementation.

WithFaultPolicy(newPolicy)
Signature: newPolicy:FaultPolicy -> IParallelismProvider
Modifiers: abstract

Creates a new scheduler instance with updated fault policy.

WithForcedLocalParallelismSetting(...)
Signature: localParallelismEnabled:bool -> IParallelismProvider
Modifiers: abstract

Creates a new distribution provider instance with toggled local parallelism semantics

WorkItemId
Signature: string
Modifiers: abstract

Get cloud work item identifier

CompiledName: get_WorkItemId

Fork me on GitHub