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
- XmlEntityReference.cs
- AspCompat.cs
- CodeTypeReferenceSerializer.cs
- FileNotFoundException.cs
- IssuedTokenServiceElement.cs
- activationcontext.cs
- VideoDrawing.cs
- TranslateTransform.cs
- ThrowHelper.cs
- CacheMemory.cs
- UIServiceHelper.cs
- StickyNoteHelper.cs
- DataColumnChangeEvent.cs
- DateTimeUtil.cs
- TemplateLookupAction.cs
- GPStream.cs
- FixUp.cs
- CodeObject.cs
- ExceptionRoutedEventArgs.cs
- SystemIcmpV4Statistics.cs
- InstanceCompleteException.cs
- TextServicesCompartment.cs
- PropertyMappingExceptionEventArgs.cs
- HandlerBase.cs
- EventMap.cs
- ColumnMap.cs
- SettingsContext.cs
- ParagraphResult.cs
- QueryExecutionOption.cs
- ViewPort3D.cs
- HttpWrapper.cs
- AndCondition.cs
- DetailsViewInsertEventArgs.cs
- DetailsViewPageEventArgs.cs
- NavigationCommands.cs
- FormCollection.cs
- InternalRelationshipCollection.cs
- NativeCompoundFileAPIs.cs
- PerspectiveCamera.cs
- XmlSchemaValidator.cs
- SchemaDeclBase.cs
- GregorianCalendarHelper.cs
- Ipv6Element.cs
- ItemDragEvent.cs
- SystemDropShadowChrome.cs
- DateTimeValueSerializer.cs
- EventArgs.cs
- DetailsViewDesigner.cs
- CodeExpressionStatement.cs
- WindowCollection.cs
- BindingCompleteEventArgs.cs
- AnnotationAdorner.cs
- SocketPermission.cs
- HtmlEncodedRawTextWriter.cs
- PageParser.cs
- RootDesignerSerializerAttribute.cs
- HuffModule.cs
- ByteStreamGeometryContext.cs
- TextDecorationCollectionConverter.cs
- ValidationResult.cs
- SafeThemeHandle.cs
- ConsoleCancelEventArgs.cs
- Rfc2898DeriveBytes.cs
- OleDbMetaDataFactory.cs
- KnownTypesProvider.cs
- InlineObject.cs
- ViewPort3D.cs
- ClientUrlResolverWrapper.cs
- WebPartDisplayModeCancelEventArgs.cs
- CommandConverter.cs
- PixelFormat.cs
- HtmlButton.cs
- OleDbException.cs
- CompilationRelaxations.cs
- ParserExtension.cs
- FormatVersion.cs
- CalendarDataBindingHandler.cs
- CustomAttribute.cs
- ColorPalette.cs
- CategoriesDocumentFormatter.cs
- RectValueSerializer.cs
- PolyBezierSegment.cs
- DecimalKeyFrameCollection.cs
- SqlWriter.cs
- ShutDownListener.cs
- Convert.cs
- ResolveCriteria.cs
- ListViewCommandEventArgs.cs
- SqlParameter.cs
- ObjectItemCollection.cs
- PathFigureCollection.cs
- ResourcePermissionBase.cs
- baseaxisquery.cs
- SoapElementAttribute.cs
- VerificationException.cs
- PenLineCapValidation.cs
- AnimatedTypeHelpers.cs
- FormView.cs
- ViewDesigner.cs
- HttpCookiesSection.cs