Code:
/ 4.0 / 4.0 / untmp / 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.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- DoWorkEventArgs.cs
- TimeSpanValidatorAttribute.cs
- _Connection.cs
- DataGridViewButtonCell.cs
- StaticSiteMapProvider.cs
- PersonalizationProvider.cs
- RedistVersionInfo.cs
- DecoderNLS.cs
- CommunicationObjectAbortedException.cs
- ToolboxBitmapAttribute.cs
- NumericPagerField.cs
- FrameworkObject.cs
- XmlIncludeAttribute.cs
- GraphicsState.cs
- CacheDependency.cs
- SafeNativeMethods.cs
- TrackBarRenderer.cs
- AnnotationDocumentPaginator.cs
- SafeHandles.cs
- DataSetUtil.cs
- DataGridViewAccessibleObject.cs
- WebPartAuthorizationEventArgs.cs
- TextContainerHelper.cs
- MetadataAssemblyHelper.cs
- KeyGestureConverter.cs
- DetailsViewRow.cs
- HttpHandlersSection.cs
- ImageDrawing.cs
- DataListCommandEventArgs.cs
- UnconditionalPolicy.cs
- CloudCollection.cs
- SqlDataSourceCommandParser.cs
- InvokePatternIdentifiers.cs
- SingleObjectCollection.cs
- ResetableIterator.cs
- XmlMtomWriter.cs
- CacheHelper.cs
- ExpressionCopier.cs
- Compiler.cs
- LayoutTableCell.cs
- PolicyLevel.cs
- PrincipalPermission.cs
- FunctionDetailsReader.cs
- RouteItem.cs
- EnterpriseServicesHelper.cs
- PartitionedDataSource.cs
- assertwrapper.cs
- Errors.cs
- InputProcessorProfilesLoader.cs
- ObjectCacheHost.cs
- PrivateFontCollection.cs
- ToolStripPanelDesigner.cs
- OptimizedTemplateContentHelper.cs
- Form.cs
- ProtectedConfigurationProviderCollection.cs
- XPathSelfQuery.cs
- ReservationCollection.cs
- BaseInfoTable.cs
- ControlPropertyNameConverter.cs
- Keyboard.cs
- ExtendedProtectionPolicy.cs
- DataSetMappper.cs
- PermissionAttributes.cs
- dtdvalidator.cs
- CodeAttributeArgumentCollection.cs
- Splitter.cs
- SqlRecordBuffer.cs
- DrawingState.cs
- InvariantComparer.cs
- AppLevelCompilationSectionCache.cs
- GifBitmapDecoder.cs
- NoneExcludedImageIndexConverter.cs
- WebConfigurationManager.cs
- MissingMemberException.cs
- OleDbError.cs
- InputScopeManager.cs
- ExtendedPropertyDescriptor.cs
- OletxCommittableTransaction.cs
- SqlMethods.cs
- TdsValueSetter.cs
- PipeStream.cs
- TreeChangeInfo.cs
- TrustManagerPromptUI.cs
- ContentControl.cs
- Converter.cs
- MetadataItem.cs
- Compiler.cs
- RelAssertionDirectKeyIdentifierClause.cs
- DataRecordInternal.cs
- DrawListViewColumnHeaderEventArgs.cs
- UriTemplateTable.cs
- RuntimeArgumentHandle.cs
- Size3D.cs
- WindowsListView.cs
- MemoryResponseElement.cs
- OrderedDictionaryStateHelper.cs
- PageThemeParser.cs
- BezierSegment.cs
- GZipDecoder.cs
- CategoryEditor.cs