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
- GenericWebPart.cs
- CachingHintValidation.cs
- PopupRoot.cs
- ProxyWebPartManagerDesigner.cs
- ToolStripRenderer.cs
- RefExpr.cs
- WorkflowItemPresenter.cs
- InternalConfigEventArgs.cs
- Method.cs
- NetNamedPipeSecurityElement.cs
- ValidationResult.cs
- SqlTransaction.cs
- ConnectivityStatus.cs
- BindingSource.cs
- ComponentSerializationService.cs
- MessageFilterException.cs
- UdpRetransmissionSettings.cs
- HtmlContainerControl.cs
- Rule.cs
- ValidatingReaderNodeData.cs
- DataGridViewTopRowAccessibleObject.cs
- FieldMetadata.cs
- BaseDataListActionList.cs
- StoreAnnotationsMap.cs
- TextElementEnumerator.cs
- CatchDesigner.xaml.cs
- UnsafeNativeMethods.cs
- AsymmetricSecurityProtocolFactory.cs
- PageDeviceFont.cs
- XPathPatternParser.cs
- TypeElement.cs
- WorkflowServiceBuildProvider.cs
- Expression.DebuggerProxy.cs
- LicFileLicenseProvider.cs
- CreateSequenceResponse.cs
- MethodBuilderInstantiation.cs
- AssemblyEvidenceFactory.cs
- TraceData.cs
- MenuItem.cs
- PropertyReferenceSerializer.cs
- SqlInternalConnectionSmi.cs
- DesignerActionUI.cs
- TraceSwitch.cs
- DynamicActivityProperty.cs
- XPathAncestorQuery.cs
- SmtpFailedRecipientsException.cs
- mactripleDES.cs
- EnvironmentPermission.cs
- ColorEditor.cs
- HtmlTitle.cs
- FullTextBreakpoint.cs
- WindowsPen.cs
- PingOptions.cs
- CodeFieldReferenceExpression.cs
- DbExpressionVisitor_TResultType.cs
- DbFunctionCommandTree.cs
- ClientRolePrincipal.cs
- CustomErrorCollection.cs
- TemplateXamlParser.cs
- ClientType.cs
- DragAssistanceManager.cs
- ServiceHostFactory.cs
- Parallel.cs
- NamedObject.cs
- TextEncodedRawTextWriter.cs
- DependencySource.cs
- XmlBufferReader.cs
- TransformerInfoCollection.cs
- Constraint.cs
- WebAdminConfigurationHelper.cs
- OracleMonthSpan.cs
- LocalizableResourceBuilder.cs
- StylusPointCollection.cs
- CompiledQuery.cs
- SByte.cs
- ChannelPoolSettings.cs
- HandledMouseEvent.cs
- Sequence.cs
- selecteditemcollection.cs
- Win32KeyboardDevice.cs
- ErrorStyle.cs
- AuthenticationService.cs
- HttpDictionary.cs
- Policy.cs
- OdbcStatementHandle.cs
- TargetInvocationException.cs
- DesignerActionVerbList.cs
- SecureStringHasher.cs
- ApplicationManager.cs
- AttributeAction.cs
- TableDetailsRow.cs
- HeaderUtility.cs
- ListSourceHelper.cs
- ConstNode.cs
- FormViewUpdatedEventArgs.cs
- Image.cs
- ConfigurationSchemaErrors.cs
- JournalEntry.cs
- WorkflowTransactionOptions.cs
- FontCacheUtil.cs