Export (0) Print
Expand All
Expand Minimize
0 out of 1 rated this helpful - Rate this topic

Microsoft.Ccr.Core Namespace

Microsoft Robotics
Microsoft Robotics Class Reference
  Class Description
Public class Arbiter
Arbiter factory
Public class Causality
Logical context that flows across tasks
Causalities greatly simplify partial failure handling, by providing a multi threaded version of structured exception handling. An exception port supplied within a causality can be used by any handler that was executed as a result of some root action. Causalities deal with joins (merge of causalities) and forks, enabling a simple model for hierarchical handling of errors in a concurrent setting
Public class CcrServiceBase
Base CCR class
Public class Choice
The choice arbiter will arbitrate between N child receivers (branches) and only allow one to proceed
Public class ConcurrentReceiverGroup
Receivers with user delegates that can run concurrently with each other
Public class Dispatcher
Implementation of the CCR Task Dispatcher/Scheduler
Public class DispatcherQueue
Special variant of a typed Port for enqueing and scheduling CCR Tasks
Public class DispatcherQueueExtensions
CCR DispatcherQueue Class Extensions
Public class EmptyValue
Utility type, with a singleton instance for use in signalling applications where no values need to be communicated
Public class ExclusiveReceiverGroup
Receivers with user delegates that must run exclusive to each other and any receiver in a Concurrent group
Public class Interleave
The Interleave arbiter is a generalization of reader/writer lock style synchronization
Public class InterleaveReceiverGroup
Receiver group
Public class IterativeTask
Zero argument Task instance associated with an iterator handler
Public class IterativeTask<(Of <(<'T0>)>)>
Container for iterator handlers and their arguments
Public class IterativeTask<(Of <(<'T0, T1>)>)>
Container for iterator handlers and their arguments
Public class IterativeTask<(Of <(<'T0, T1, T2>)>)>
Container for iterator handlers and their arguments
Public class JoinReceiver
Join implementation across multiple ports
Public class JoinReceiverTask
Shared logic for join arbiters
Public class JoinSinglePortReceiver
Join receiver that waits for N items all on the same port
Public class MultipleItemGather
Collects N messages from K ports, then executes a task passing K typed collections of messages
Public class MultipleItemReceiver
Collects N messages from N ports, then executes a task passing a collection with N messages
Public class Port<(Of <(<'T>)>)>
Type safe message queue and receiver attach point for the CCR.
Public class PortExtensions
Port extension methods for coordination primitive creation
Public class PortNotFoundException
Thrown when a message instance of incompatible type is posted on a Port instance
Public class PortSet
Multiple Queue Port composed out of multiple Port<T> instances, one for each type specified at runtime
For each type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the Ports accessor
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16, T17, T18, T19>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSet<(Of <(<'T0, T1, T2, T3, T4, T5, T6, T7, T8>)>)>
Multiple Queue Port composed out of multiple Port<T> instances, one for each type
For each generic type argument T, an instance of Port<T> is used to store messages of that type Each Port<T> instance is independent of the others and there are non ordering guarantees across ports under the same multiple port wrapper. To get access to the individual ports use the P0,P1,...,PN accessors
Public class PortSetExtensions
PortSet extension methods for coordination primitive creation
Public class Receiver
The most basic arbiter associates a user delegate (a receiver) with a port
Public class Receiver<(Of <(<'T>)>)>
Strongly typed version of Receiver
Public class Shutdown
Generic message type to signle shutdown.
Public class SuccessFailurePort
Port collection with ports typed for SuccessResult and Exception
Public class SuccessResult
Indicates success result
Public class Task
Implementation of ITask for zero argument handlers
Public class Task<(Of <(<'T0>)>)>
Container for typed, non-iterator handlers and their arguments
Public class Task<(Of <(<'T0, T1>)>)>
Container for typed, non-iterator handlers and their arguments
Public class Task<(Of <(<'T0, T1, T2>)>)>
Container for typed, non-iterator handlers and their arguments
Public class TaskCommon
Common base class for ITask implementations
Public class TeardownReceiverGroup
Receivers that will execute one time only after all concurrent and exclusive handlers are finished. The interleave will then un register all receivers from ports and prevent any further handlers form executing. If multiple teardown receivers are present, only one will execute, the one that first has its constraints (first one that receives a message for simple receives) met.
Public class Tuple<(Of <(<'ITEM0>)>)>
A type-safe, type-heterogeneous, item collection used for joins.
Public class Tuple<(Of <(<'ITEM0, ITEM1>)>)>
A type-safe, type-heterogeneous, item collection used for joins.
Public class VariableArgumentTask<(Of <(<'T>)>)>
A Task container with a variable number of typed arguments.
Public class VariableArgumentTask<(Of <(<'T0, T>)>)>
A Task container with a variable number of typed arguments.
  Interface Description
Public interface ICausality
Context for propagating failure and coordination ports across tasks
Public interface IPort
Core interface abstracting CCR single type ports
Public interface IPortReceive
Receiver registration and dequeuing methods for ports
Public interface IPortSet
Required interface for multiple type ports with independent message queues
Public interface ITask
Container for executable CCR code
Implementation of the Task interface allows code to execute in the context of the CCR dispatcher. Arbiters, receive thunks, and unguarded user delegates can use ITask to execute in arbitrary context.
  Delegate Description
Public delegate Handler
Closure signature for message handler.
Public delegate Handler<(Of <(<'T0>)>)>
Closure signature for message handler.
Public delegate Handler<(Of <(<'T0, T1>)>)>
Closure signature for message handler.
Public delegate Handler<(Of <(<'T0, T1, T2>)>)>
Closure signature for message handler.
Public delegate IteratorHandler
Closure signature for iterator-based message handler.
Public delegate IteratorHandler<(Of <(<'T0>)>)>
Closure signature for iterator-based message handler.
Public delegate IteratorHandler<(Of <(<'T0, T1>)>)>
Closure signature for iterator-based message handler.
Public delegate IteratorHandler<(Of <(<'T0, T1, T2>)>)>
Closure signature for iterator-based message handler.
Public delegate VariableArgumentHandler<(Of <(<'T>)>)>
A typed delegate with a variable number of typed arguments preceding an array of instances of the same type.
Public delegate VariableArgumentHandler<(Of <(<'T0, T>)>)>
A typed delegate with a variable number of typed arguments preceding an array of instances of the same type.
Used as the continuation to join variable and joinarray
  Enumeration Description
Public enumeration DispatcherOptions
Dispatcher configuration options
Public enumeration InterleaveReceivers
Classification of interleave receiver groups
Public enumeration TaskExecutionPolicy
Specifies dispatcher queue task scheduling behavior
Did you find this helpful?
(1500 characters remaining)
Thank you for your feedback
Show:
© 2014 Microsoft. All rights reserved.