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
- TextWriterEngine.cs
- DesignTimeHTMLTextWriter.cs
- CqlErrorHelper.cs
- EndOfStreamException.cs
- ApplicationActivator.cs
- CreateParams.cs
- HtmlInputReset.cs
- DbTransaction.cs
- ObjectConverter.cs
- AffineTransform3D.cs
- BeginStoryboard.cs
- ContextMenu.cs
- DataColumnPropertyDescriptor.cs
- DataSourceSelectArguments.cs
- XmlHierarchyData.cs
- UpdateRecord.cs
- CornerRadiusConverter.cs
- GatewayDefinition.cs
- OleDbConnectionInternal.cs
- ActiveXContainer.cs
- DataBindingExpressionBuilder.cs
- XmlSchemaSimpleType.cs
- SingleTagSectionHandler.cs
- EventLogPermission.cs
- SplayTreeNode.cs
- Overlapped.cs
- XmlCollation.cs
- PackageRelationship.cs
- HttpCapabilitiesEvaluator.cs
- RadialGradientBrush.cs
- BuildProvider.cs
- AlignmentXValidation.cs
- DependencyPropertyKey.cs
- xmlformatgeneratorstatics.cs
- DetailsView.cs
- TraceContext.cs
- WindowsHyperlink.cs
- ProcessStartInfo.cs
- CalculatedColumn.cs
- ObjectIDGenerator.cs
- RestHandler.cs
- DependencyPropertyKey.cs
- Annotation.cs
- DesignerActionUI.cs
- XpsFilter.cs
- InertiaTranslationBehavior.cs
- EndPoint.cs
- DeflateEmulationStream.cs
- ResolveNextArgumentWorkItem.cs
- ChtmlCalendarAdapter.cs
- MemberAccessException.cs
- MonthChangedEventArgs.cs
- CodeIndexerExpression.cs
- FileStream.cs
- StoragePropertyMapping.cs
- DispatchOperationRuntime.cs
- ExpressionBuilderCollection.cs
- TextRunCache.cs
- HttpCacheVaryByContentEncodings.cs
- SecureUICommand.cs
- BitmapFrameEncode.cs
- TabletDevice.cs
- TypeBinaryExpression.cs
- ADMembershipProvider.cs
- SQLDateTimeStorage.cs
- FixedTextSelectionProcessor.cs
- StoragePropertyMapping.cs
- Rotation3D.cs
- ItemsChangedEventArgs.cs
- ProofTokenCryptoHandle.cs
- DrawingImage.cs
- AttributeData.cs
- FixedSOMLineRanges.cs
- ListViewUpdatedEventArgs.cs
- WorkflowDesignerColors.cs
- DesignerTextBoxAdapter.cs
- NavigationWindowAutomationPeer.cs
- SmuggledIUnknown.cs
- BitArray.cs
- ActivityWithResult.cs
- TrackingMemoryStreamFactory.cs
- BaseParser.cs
- dbenumerator.cs
- SamlAuthorizationDecisionStatement.cs
- LeaseManager.cs
- HttpWriter.cs
- Control.cs
- XmlSchemaSimpleTypeList.cs
- SQLInt32.cs
- GridItem.cs
- OpCodes.cs
- KeyTime.cs
- Splitter.cs
- SystemTcpConnection.cs
- DataServiceStreamResponse.cs
- HTMLTagNameToTypeMapper.cs
- EventMappingSettingsCollection.cs
- CompressedStack.cs
- RefreshEventArgs.cs
- SecurityTokenAuthenticator.cs