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
- SuppressIldasmAttribute.cs
- Directory.cs
- Stroke.cs
- SmiEventSink_Default.cs
- JsonObjectDataContract.cs
- CodeMemberProperty.cs
- SQLDateTime.cs
- RenderData.cs
- TraceLevelStore.cs
- SQLString.cs
- MetaModel.cs
- GPRECT.cs
- COSERVERINFO.cs
- GenericAuthenticationEventArgs.cs
- BigInt.cs
- CodeAttributeArgumentCollection.cs
- HtmlFormParameterWriter.cs
- NonParentingControl.cs
- XmlRootAttribute.cs
- ResourceReferenceKeyNotFoundException.cs
- XamlBuildTaskServices.cs
- EntityCollection.cs
- FixedPageProcessor.cs
- ElapsedEventArgs.cs
- CharStorage.cs
- OleDbCommand.cs
- AspNetCacheProfileAttribute.cs
- EditableRegion.cs
- TraceLog.cs
- Timer.cs
- ValidationSummary.cs
- Polygon.cs
- DesignTimeType.cs
- StylusCaptureWithinProperty.cs
- arabicshape.cs
- HttpInputStream.cs
- TableDetailsRow.cs
- DocumentCollection.cs
- SendDesigner.xaml.cs
- CodePageUtils.cs
- DrawListViewColumnHeaderEventArgs.cs
- FixedSOMImage.cs
- FlowPosition.cs
- MetaData.cs
- ObjectItemAssemblyLoader.cs
- CommandHelper.cs
- DynamicResourceExtension.cs
- ResolveCriteria11.cs
- SimpleApplicationHost.cs
- SqlExpressionNullability.cs
- DiscoveryExceptionDictionary.cs
- UInt16.cs
- ReadOnlyPropertyMetadata.cs
- ImmComposition.cs
- Size3D.cs
- GlobalizationAssembly.cs
- NegatedCellConstant.cs
- ResumeStoryboard.cs
- ImageCodecInfoPrivate.cs
- OdbcErrorCollection.cs
- Rectangle.cs
- DataGridViewUtilities.cs
- CompModHelpers.cs
- OleCmdHelper.cs
- XmlTextReaderImpl.cs
- EntityDataSourceDesigner.cs
- ServiceDebugElement.cs
- MetabaseServerConfig.cs
- ConfigurationUtility.cs
- AuthenticationConfig.cs
- HelpInfo.cs
- InteropAutomationProvider.cs
- DataGridViewCellStyleContentChangedEventArgs.cs
- EditBehavior.cs
- IdentityNotMappedException.cs
- Random.cs
- BuildManagerHost.cs
- ExtendedProtectionPolicy.cs
- ScriptResourceInfo.cs
- TimeSpanMinutesConverter.cs
- JsonQNameDataContract.cs
- TemplatedMailWebEventProvider.cs
- FormView.cs
- EncodingDataItem.cs
- localization.cs
- HostingEnvironmentException.cs
- SystemFonts.cs
- Shape.cs
- DataGridAutomationPeer.cs
- DependencyObject.cs
- ListComponentEditor.cs
- ListBoxItemWrapperAutomationPeer.cs
- ConfigurationManagerHelperFactory.cs
- CultureInfoConverter.cs
- ConfigXmlElement.cs
- ListBox.cs
- ScriptingSectionGroup.cs
- ToolZone.cs
- WhitespaceSignificantCollectionAttribute.cs
- SqlSelectStatement.cs