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
- Image.cs
- Floater.cs
- Pair.cs
- PlainXmlDeserializer.cs
- ButtonField.cs
- SqlConnectionFactory.cs
- HeaderedItemsControl.cs
- SizeAnimationClockResource.cs
- AlphaSortedEnumConverter.cs
- SqlWebEventProvider.cs
- ManagementOptions.cs
- RulePatternOps.cs
- LocationEnvironment.cs
- ToolStripContainer.cs
- GeneratedContractType.cs
- TemplateField.cs
- Highlights.cs
- OuterProxyWrapper.cs
- WebGetAttribute.cs
- CroppedBitmap.cs
- DataGridViewRowHeaderCell.cs
- XmlSchemaSubstitutionGroup.cs
- AttributeCollection.cs
- ListViewContainer.cs
- WebPartsPersonalizationAuthorization.cs
- XmlReaderDelegator.cs
- XmlQueryTypeFactory.cs
- LabelAutomationPeer.cs
- DataGridViewImageColumn.cs
- PersianCalendar.cs
- DeploymentExceptionMapper.cs
- DataGridViewColumnHeaderCell.cs
- Win32.cs
- DynamicDataManager.cs
- ToolStripArrowRenderEventArgs.cs
- LinqDataSourceContextData.cs
- ResourceExpressionBuilder.cs
- ActivityExecutorDelegateInfo.cs
- NextPreviousPagerField.cs
- MultitargetingHelpers.cs
- RayHitTestParameters.cs
- CodeRegionDirective.cs
- GridViewRowEventArgs.cs
- MethodSet.cs
- PeerApplicationLaunchInfo.cs
- SQLDateTime.cs
- invalidudtexception.cs
- ApplicationTrust.cs
- SafeCloseHandleCritical.cs
- IPEndPointCollection.cs
- SqlDataSourceCustomCommandPanel.cs
- ErrorStyle.cs
- TagPrefixInfo.cs
- GridViewSortEventArgs.cs
- EntityViewGenerator.cs
- SessionState.cs
- FigureParaClient.cs
- ChildrenQuery.cs
- RowUpdatedEventArgs.cs
- RequestCacheValidator.cs
- LogPolicy.cs
- ViewSimplifier.cs
- OpacityConverter.cs
- HTTP_SERVICE_CONFIG_URLACL_PARAM.cs
- CategoryAttribute.cs
- MetadataArtifactLoaderXmlReaderWrapper.cs
- HTMLTextWriter.cs
- SqlCrossApplyToCrossJoin.cs
- AuthenticationManager.cs
- TemplateKey.cs
- COM2FontConverter.cs
- SmtpReplyReader.cs
- FacetEnabledSchemaElement.cs
- CustomExpression.cs
- ApplicationHost.cs
- AddressingProperty.cs
- ActivationServices.cs
- DataGridViewCellConverter.cs
- ReachDocumentPageSerializerAsync.cs
- ControlBuilderAttribute.cs
- ResourceDisplayNameAttribute.cs
- X509RawDataKeyIdentifierClause.cs
- WebPartExportVerb.cs
- SecurityToken.cs
- OleDbStruct.cs
- Emitter.cs
- TypeForwardedToAttribute.cs
- CodeTypeDeclaration.cs
- GridPattern.cs
- ProcessHostConfigUtils.cs
- VisualStyleInformation.cs
- ArrayConverter.cs
- TypeConstant.cs
- RelationshipSet.cs
- ObjectDataSourceSelectingEventArgs.cs
- MimeTypeAttribute.cs
- VisualStyleRenderer.cs
- HyperLink.cs
- AnnotationMap.cs
- UserPreference.cs