Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / Enumerables / ParallelQuery.cs / 1305376 / ParallelQuery.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // ParallelQuery.cs // //[....] // // ParallelQuery is an abstract class that represents a PLINQ query. // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections; using System.Collections.Generic; using System.Linq.Parallel; using System.Diagnostics.Contracts; namespace System.Linq { ////// Represents a parallel sequence. /// public class ParallelQuery : IEnumerable { // Settings that have been specified on the query so far. private QuerySettings m_specifiedSettings; internal ParallelQuery(QuerySettings specifiedSettings) { m_specifiedSettings = specifiedSettings; } //------------------------------------------------------------------------------------ // Settings that have been specified on the query so far. Some settings may still // be unspecified and will be replaced either by operators further in the query, // or filled in with defaults at query opening time. // internal QuerySettings SpecifiedQuerySettings { get { return m_specifiedSettings; } } //----------------------------------------------------------------------------------- // Returns a parallel enumerable that represents 'this' enumerable, with each element // casted to TCastTo. If some element is not of type TCastTo, InvalidCastException // is thrown. // internal virtual ParallelQueryCast () { Contract.Assert(false, "The derived class must override this method."); throw new NotSupportedException(); } //----------------------------------------------------------------------------------- // Returns a parallel enumerable that represents 'this' enumerable, with each element // casted to TCastTo. Elements that are not of type TCastTo will be left out from // the results. // internal virtual ParallelQuery OfType () { Contract.Assert(false, "The derived class must override this method."); throw new NotSupportedException(); } //----------------------------------------------------------------------------------- // Derived classes implement GetEnumeratorUntyped() instead of IEnumerable.GetEnumerator() // This is to avoid the method name conflict if the derived classes also implement // IEnumerable . // internal virtual IEnumerator GetEnumeratorUntyped() { Contract.Assert(false, "The derived class must override this method."); throw new NotSupportedException(); } /// /// Returns an enumerator that iterates through the sequence. /// ///An enumerator that iterates through the sequence. IEnumerator IEnumerable.GetEnumerator() { return GetEnumeratorUntyped(); } } ////// Represents a parallel sequence. /// public class ParallelQuery: ParallelQuery, IEnumerable { internal ParallelQuery(QuerySettings settings) : base(settings) { } internal sealed override ParallelQuery Cast () { return ParallelEnumerable.Select (this, elem => (TCastTo)(object)elem); } internal sealed override ParallelQuery OfType () { // @PERF: Currently defined in terms of other operators. This isn't the most performant // solution (because it results in two operators) but is simple to implement. return this .Where (elem => elem is TCastTo) .Select (elem => (TCastTo)(object)elem); } internal override IEnumerator GetEnumeratorUntyped() { return ((IEnumerable )this).GetEnumerator(); } /// /// Returns an enumerator that iterates through the sequence. /// ///An enumerator that iterates through the sequence. public virtual IEnumeratorGetEnumerator() { Contract.Assert(false, "The derived class must override this method."); throw new NotSupportedException(); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // ParallelQuery.cs // // [....] // // ParallelQuery is an abstract class that represents a PLINQ query. // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections; using System.Collections.Generic; using System.Linq.Parallel; using System.Diagnostics.Contracts; namespace System.Linq { ////// Represents a parallel sequence. /// public class ParallelQuery : IEnumerable { // Settings that have been specified on the query so far. private QuerySettings m_specifiedSettings; internal ParallelQuery(QuerySettings specifiedSettings) { m_specifiedSettings = specifiedSettings; } //------------------------------------------------------------------------------------ // Settings that have been specified on the query so far. Some settings may still // be unspecified and will be replaced either by operators further in the query, // or filled in with defaults at query opening time. // internal QuerySettings SpecifiedQuerySettings { get { return m_specifiedSettings; } } //----------------------------------------------------------------------------------- // Returns a parallel enumerable that represents 'this' enumerable, with each element // casted to TCastTo. If some element is not of type TCastTo, InvalidCastException // is thrown. // internal virtual ParallelQueryCast () { Contract.Assert(false, "The derived class must override this method."); throw new NotSupportedException(); } //----------------------------------------------------------------------------------- // Returns a parallel enumerable that represents 'this' enumerable, with each element // casted to TCastTo. Elements that are not of type TCastTo will be left out from // the results. // internal virtual ParallelQuery OfType () { Contract.Assert(false, "The derived class must override this method."); throw new NotSupportedException(); } //----------------------------------------------------------------------------------- // Derived classes implement GetEnumeratorUntyped() instead of IEnumerable.GetEnumerator() // This is to avoid the method name conflict if the derived classes also implement // IEnumerable . // internal virtual IEnumerator GetEnumeratorUntyped() { Contract.Assert(false, "The derived class must override this method."); throw new NotSupportedException(); } /// /// Returns an enumerator that iterates through the sequence. /// ///An enumerator that iterates through the sequence. IEnumerator IEnumerable.GetEnumerator() { return GetEnumeratorUntyped(); } } ////// Represents a parallel sequence. /// public class ParallelQuery: ParallelQuery, IEnumerable { internal ParallelQuery(QuerySettings settings) : base(settings) { } internal sealed override ParallelQuery Cast () { return ParallelEnumerable.Select (this, elem => (TCastTo)(object)elem); } internal sealed override ParallelQuery OfType () { // @PERF: Currently defined in terms of other operators. This isn't the most performant // solution (because it results in two operators) but is simple to implement. return this .Where (elem => elem is TCastTo) .Select (elem => (TCastTo)(object)elem); } internal override IEnumerator GetEnumeratorUntyped() { return ((IEnumerable )this).GetEnumerator(); } /// /// Returns an enumerator that iterates through the sequence. /// ///An enumerator that iterates through the sequence. public virtual IEnumeratorGetEnumerator() { Contract.Assert(false, "The derived class must override this method."); throw new NotSupportedException(); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ResetableIterator.cs
- EntityDataSourceState.cs
- MessageHeaderDescription.cs
- EntitySetRetriever.cs
- Timer.cs
- InkCollectionBehavior.cs
- ControlType.cs
- SimpleBitVector32.cs
- SpellerInterop.cs
- GeometryModel3D.cs
- QueryCacheEntry.cs
- CollaborationHelperFunctions.cs
- BroadcastEventHelper.cs
- ObjectItemAttributeAssemblyLoader.cs
- remotingproxy.cs
- SqlNotificationEventArgs.cs
- DependencyObjectProvider.cs
- ManagementEventWatcher.cs
- RunInstallerAttribute.cs
- PrintDialog.cs
- ComponentEditorPage.cs
- DynamicExpression.cs
- GcSettings.cs
- HwndKeyboardInputProvider.cs
- SwitchElementsCollection.cs
- SqlCacheDependencyDatabaseCollection.cs
- HostingEnvironment.cs
- X509CertificateCollection.cs
- PeerCustomResolverSettings.cs
- SimpleApplicationHost.cs
- InstanceCreationEditor.cs
- WebFormsRootDesigner.cs
- FixedHyperLink.cs
- CmsInterop.cs
- DataMemberConverter.cs
- NetMsmqSecurityMode.cs
- RuleSettings.cs
- HostedHttpRequestAsyncResult.cs
- OleDbFactory.cs
- SqlDataSourceEnumerator.cs
- CellIdBoolean.cs
- FixedSOMFixedBlock.cs
- StrongBox.cs
- XmlParserContext.cs
- Light.cs
- BitHelper.cs
- SafeProcessHandle.cs
- FixUp.cs
- BrowserInteropHelper.cs
- SetIterators.cs
- NetNamedPipeSecurityMode.cs
- CompositeControlDesigner.cs
- ImageMetadata.cs
- datacache.cs
- LogSwitch.cs
- ColorAnimationBase.cs
- ZipIOCentralDirectoryFileHeader.cs
- GACIdentityPermission.cs
- DescendantQuery.cs
- DetailsViewUpdatedEventArgs.cs
- WebPartDeleteVerb.cs
- Tokenizer.cs
- Screen.cs
- ErrorTableItemStyle.cs
- RowBinding.cs
- DbConnectionPoolGroup.cs
- ColorInterpolationModeValidation.cs
- MailHeaderInfo.cs
- DefaultHttpHandler.cs
- DataGridColumnHeaderItemAutomationPeer.cs
- ConfigXmlText.cs
- Serializer.cs
- IndependentlyAnimatedPropertyMetadata.cs
- FigureParagraph.cs
- EnumType.cs
- FlatButtonAppearance.cs
- WebPartTransformer.cs
- TabControlCancelEvent.cs
- GCHandleCookieTable.cs
- AttachedPropertyMethodSelector.cs
- DataGridViewCellStateChangedEventArgs.cs
- XmlDeclaration.cs
- ListControl.cs
- NameValuePair.cs
- TemplateNodeContextMenu.cs
- WebConfigurationFileMap.cs
- Configuration.cs
- SelectionManager.cs
- StringReader.cs
- ServiceOperationListItemList.cs
- SystemKeyConverter.cs
- TextEndOfParagraph.cs
- BamlCollectionHolder.cs
- LayoutTableCell.cs
- Page.cs
- RuleSettingsCollection.cs
- DataTableMappingCollection.cs
- CollectionBuilder.cs
- ServiceX509SecurityTokenProvider.cs
- BinaryObjectInfo.cs