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
- NullExtension.cs
- ReferentialConstraintRoleElement.cs
- UIElement.cs
- RegexCaptureCollection.cs
- SystemIcons.cs
- BaseResourcesBuildProvider.cs
- ViewLoader.cs
- AssociationType.cs
- SiteMapNodeItem.cs
- DataGridViewColumnEventArgs.cs
- DataControlLinkButton.cs
- FaultDescription.cs
- processwaithandle.cs
- DataSourceHelper.cs
- XmlSchemaElement.cs
- SchemaTableColumn.cs
- util.cs
- SmtpClient.cs
- BodyGlyph.cs
- Schema.cs
- DataGridViewColumnCollection.cs
- WebReferencesBuildProvider.cs
- RoleExceptions.cs
- IssuedTokenServiceCredential.cs
- StateMachine.cs
- DocumentPaginator.cs
- HandoffBehavior.cs
- RenderDataDrawingContext.cs
- SqlTransaction.cs
- LogEntryUtils.cs
- MessageProperties.cs
- WorkflowTransactionService.cs
- CompareValidator.cs
- UnauthorizedAccessException.cs
- ConstructorNeedsTagAttribute.cs
- StreamInfo.cs
- PrimitiveCodeDomSerializer.cs
- SqlConnectionPoolGroupProviderInfo.cs
- HostExecutionContextManager.cs
- DisplayToken.cs
- ObfuscateAssemblyAttribute.cs
- InvalidDataException.cs
- ProcessHostFactoryHelper.cs
- DynamicObject.cs
- LiteralControl.cs
- MSAANativeProvider.cs
- ParameterCollection.cs
- IDataContractSurrogate.cs
- ThreadSafeList.cs
- MergeFilterQuery.cs
- AttributeCollection.cs
- CatalogZone.cs
- LiteralSubsegment.cs
- Condition.cs
- CalendarSelectionChangedEventArgs.cs
- CodeDomDesignerLoader.cs
- DiagnosticTraceSource.cs
- RectangleHotSpot.cs
- MultiPartWriter.cs
- ControlCodeDomSerializer.cs
- RowCache.cs
- ObservableCollectionDefaultValueFactory.cs
- ReachDocumentReferenceSerializerAsync.cs
- MaskedTextBoxTextEditorDropDown.cs
- DataViewSetting.cs
- ToolBarTray.cs
- basemetadatamappingvisitor.cs
- SectionInput.cs
- ProcessStartInfo.cs
- RecordsAffectedEventArgs.cs
- PageSetupDialog.cs
- MatrixCamera.cs
- SHA384Managed.cs
- ExtendedPropertiesHandler.cs
- StubHelpers.cs
- RSACryptoServiceProvider.cs
- RequiredFieldValidator.cs
- DataGridViewCheckBoxCell.cs
- EqualityArray.cs
- Currency.cs
- ScrollEventArgs.cs
- HttpCookieCollection.cs
- MatrixAnimationUsingPath.cs
- ConvertersCollection.cs
- DataSourceSelectArguments.cs
- TransportChannelFactory.cs
- DbProviderFactories.cs
- HtmlPageAdapter.cs
- SBCSCodePageEncoding.cs
- BinaryHeap.cs
- PathSegment.cs
- MasterPageCodeDomTreeGenerator.cs
- XPathExpr.cs
- XmlSchemaComplexContentExtension.cs
- ObjectDataSourceView.cs
- DataRecordInfo.cs
- SiteMapPath.cs
- BulletChrome.cs
- MessageBox.cs
- CodeTypeConstructor.cs