Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / QueryOperatorEnumerator.cs / 1305376 / QueryOperatorEnumerator.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // QueryOperatorEnumerator.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections; using System.Collections.Generic; using System.Diagnostics.Contracts; namespace System.Linq.Parallel { ////// A common enumerator type that unifies all query operator enumerators. /// ////// internal abstract class QueryOperatorEnumerator { // Moves the position of the enumerator forward by one, and simultaneously returns // the (new) current element and key. If empty, false is returned. internal abstract bool MoveNext(ref TElement currentElement, ref TKey currentKey); // Standard implementation of the disposable pattern. public void Dispose() { Dispose(true); } protected virtual void Dispose(bool disposing) { // This is a no-op by default. Subclasses can override. } internal virtual void Reset() { // This is a no-op by default. Subclasses can override. } //------------------------------------------------------------------------------------ // A simple way to turn a query operator enumerator into a "classic" one. // internal IEnumerator AsClassicEnumerator() { return new QueryOperatorClassicEnumerator(this); } class QueryOperatorClassicEnumerator : IEnumerator { private QueryOperatorEnumerator m_operatorEnumerator; private TElement m_current; internal QueryOperatorClassicEnumerator(QueryOperatorEnumerator operatorEnumerator) { Contract.Assert(operatorEnumerator != null); m_operatorEnumerator = operatorEnumerator; } public bool MoveNext() { TKey keyUnused = default(TKey); return m_operatorEnumerator.MoveNext(ref m_current, ref keyUnused); } public TElement Current { get { return m_current; } } object IEnumerator.Current { get { return m_current; } } public void Dispose() { m_operatorEnumerator.Dispose(); m_operatorEnumerator = null; } public void Reset() { m_operatorEnumerator.Reset(); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // QueryOperatorEnumerator.cs // // [....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections; using System.Collections.Generic; using System.Diagnostics.Contracts; namespace System.Linq.Parallel { ////// A common enumerator type that unifies all query operator enumerators. /// ////// internal abstract class QueryOperatorEnumerator { // Moves the position of the enumerator forward by one, and simultaneously returns // the (new) current element and key. If empty, false is returned. internal abstract bool MoveNext(ref TElement currentElement, ref TKey currentKey); // Standard implementation of the disposable pattern. public void Dispose() { Dispose(true); } protected virtual void Dispose(bool disposing) { // This is a no-op by default. Subclasses can override. } internal virtual void Reset() { // This is a no-op by default. Subclasses can override. } //------------------------------------------------------------------------------------ // A simple way to turn a query operator enumerator into a "classic" one. // internal IEnumerator AsClassicEnumerator() { return new QueryOperatorClassicEnumerator(this); } class QueryOperatorClassicEnumerator : IEnumerator { private QueryOperatorEnumerator m_operatorEnumerator; private TElement m_current; internal QueryOperatorClassicEnumerator(QueryOperatorEnumerator operatorEnumerator) { Contract.Assert(operatorEnumerator != null); m_operatorEnumerator = operatorEnumerator; } public bool MoveNext() { TKey keyUnused = default(TKey); return m_operatorEnumerator.MoveNext(ref m_current, ref keyUnused); } public TElement Current { get { return m_current; } } object IEnumerator.Current { get { return m_current; } } public void Dispose() { m_operatorEnumerator.Dispose(); m_operatorEnumerator = null; } public void Reset() { m_operatorEnumerator.Reset(); } } } } // 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
- FrameworkContentElement.cs
- _SslSessionsCache.cs
- ConfigsHelper.cs
- EntryWrittenEventArgs.cs
- OpacityConverter.cs
- PrintDialogException.cs
- DeferredElementTreeState.cs
- FormViewUpdateEventArgs.cs
- UserNamePasswordClientCredential.cs
- CryptoProvider.cs
- SizeF.cs
- ProxyFragment.cs
- WorkflowPageSetupDialog.cs
- AsyncDataRequest.cs
- DrawToolTipEventArgs.cs
- SimpleWebHandlerParser.cs
- PageCatalogPartDesigner.cs
- FormViewInsertEventArgs.cs
- ImpersonateTokenRef.cs
- TypeUsage.cs
- Column.cs
- EventsTab.cs
- MatrixValueSerializer.cs
- BuildProvider.cs
- SchemaConstraints.cs
- RightNameExpirationInfoPair.cs
- ByteFacetDescriptionElement.cs
- ObjectQueryState.cs
- DataGridCell.cs
- HitTestParameters.cs
- ConsumerConnectionPoint.cs
- SqlInternalConnectionSmi.cs
- XamlDesignerSerializationManager.cs
- PaperSource.cs
- MainMenu.cs
- ExpressionBindingCollection.cs
- DataControlFieldCell.cs
- MailWriter.cs
- DependencyPropertyKey.cs
- EncryptedPackage.cs
- BindingListCollectionView.cs
- WebPartExportVerb.cs
- UInt32.cs
- SimpleHandlerBuildProvider.cs
- RecordsAffectedEventArgs.cs
- ErrorFormatterPage.cs
- PathTooLongException.cs
- XmlNullResolver.cs
- DataSourceControlBuilder.cs
- HwndKeyboardInputProvider.cs
- ConnectionManagementElement.cs
- CodeTypeReferenceCollection.cs
- OleDbCommandBuilder.cs
- DispatcherExceptionFilterEventArgs.cs
- QueryCreatedEventArgs.cs
- Win32.cs
- _ReceiveMessageOverlappedAsyncResult.cs
- Soap12ServerProtocol.cs
- Maps.cs
- Condition.cs
- SqlXmlStorage.cs
- TextServicesCompartmentEventSink.cs
- Crc32Helper.cs
- VolatileEnlistmentState.cs
- CachedFontFace.cs
- Models.cs
- DeleteCardRequest.cs
- MembershipUser.cs
- EncoderNLS.cs
- HotCommands.cs
- TokenizerHelper.cs
- CodeExpressionStatement.cs
- PropertyStore.cs
- Polygon.cs
- FacetValues.cs
- RoleManagerSection.cs
- StylusOverProperty.cs
- GeneralTransform2DTo3D.cs
- AssemblyNameProxy.cs
- UpdatePanelTrigger.cs
- DBBindings.cs
- TextProperties.cs
- WmpBitmapEncoder.cs
- KeyValueSerializer.cs
- BaseParser.cs
- DesignerInterfaces.cs
- CLRBindingWorker.cs
- SoapProcessingBehavior.cs
- FilterElement.cs
- TextEndOfSegment.cs
- AuthStoreRoleProvider.cs
- ModelItemImpl.cs
- propertyentry.cs
- UnsafeNativeMethods.cs
- ThreadAbortException.cs
- WebException.cs
- XmlValueConverter.cs
- DataPager.cs
- FaultPropagationRecord.cs
- SplashScreenNativeMethods.cs