Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / Inlined / LongSumAggregationOperator.cs / 1305376 / LongSumAggregationOperator.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // LongSumAggregationOperator.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections.Generic; using System.Diagnostics.Contracts; using System.Threading; namespace System.Linq.Parallel { ////// An inlined sum aggregation and its enumerator, for longs. /// internal sealed class LongSumAggregationOperator : InlinedAggregationOperator{ //---------------------------------------------------------------------------------------- // Constructs a new instance of a sum associative operator. // internal LongSumAggregationOperator(IEnumerable child) : base(child) { } //--------------------------------------------------------------------------------------- // Executes the entire query tree, and aggregates the intermediate results into the // final result based on the binary operators and final reduction. // // Return Value: // The single result of aggregation. // protected override long InternalAggregate(ref Exception singularExceptionToThrow) { // Because the final reduction is typically much cheaper than the intermediate // reductions over the individual partitions, and because each parallel partition // will do a lot of work to produce a single output element, we prefer to turn off // pipelining, and process the final reductions serially. using (IEnumerator enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true)) { // We just reduce the elements in each output partition. long sum = 0L; while (enumerator.MoveNext()) { checked { sum += enumerator.Current; } } return sum; } } //--------------------------------------------------------------------------------------- // Creates an enumerator that is used internally for the final aggregation step. // protected override QueryOperatorEnumerator CreateEnumerator ( int index, int count, QueryOperatorEnumerator source, object sharedData, CancellationToken cancellationToken) { return new LongSumAggregationOperatorEnumerator (source, index, cancellationToken); } //--------------------------------------------------------------------------------------- // This enumerator type encapsulates the intermediary aggregation over the underlying // (possibly partitioned) data source. // private class LongSumAggregationOperatorEnumerator : InlinedAggregationOperatorEnumerator { private readonly QueryOperatorEnumerator m_source; // The source data. //---------------------------------------------------------------------------------------- // Instantiates a new aggregation operator. // internal LongSumAggregationOperatorEnumerator(QueryOperatorEnumerator source, int partitionIndex, CancellationToken cancellationToken) : base(partitionIndex, cancellationToken) { Contract.Assert(source != null); m_source = source; } //--------------------------------------------------------------------------------------- // Tallies up the sum of the underlying data source, walking the entire thing the first // time MoveNext is called on this object. // protected override bool MoveNextCore(ref long currentElement) { long element = default(long); TKey keyUnused = default(TKey); QueryOperatorEnumerator source = m_source; if (source.MoveNext(ref element, ref keyUnused)) { // We just scroll through the enumerator and accumulate the sum. long tempSum = 0L; int i = 0; do { if ((i++ & CancellationState.POLL_INTERVAL) == 0) CancellationState.ThrowIfCanceled(m_cancellationToken); checked { tempSum += element; } } while (source.MoveNext(ref element, ref keyUnused)); // The sum has been calculated. Now just return. currentElement = tempSum; return true; } return false; } //---------------------------------------------------------------------------------------- // Dispose of resources associated with the underlying enumerator. // protected override void Dispose(bool disposing) { Contract.Assert(m_source != null); m_source.Dispose(); } } } } // 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
- Vertex.cs
- XmlSchemaValidator.cs
- GenerateHelper.cs
- SelectorItemAutomationPeer.cs
- TextFormatterHost.cs
- CompiledAction.cs
- Column.cs
- UserControlParser.cs
- SecurityTokenProvider.cs
- BStrWrapper.cs
- CompilerResults.cs
- SQLInt64Storage.cs
- XamlPointCollectionSerializer.cs
- IUnknownConstantAttribute.cs
- HttpModuleCollection.cs
- DataRelation.cs
- HttpCachePolicyWrapper.cs
- Graphics.cs
- CompoundFileStreamReference.cs
- EventListener.cs
- Material.cs
- CombinedGeometry.cs
- SendOperation.cs
- StartFileNameEditor.cs
- RoleServiceManager.cs
- BindingNavigator.cs
- OdbcConnectionPoolProviderInfo.cs
- unitconverter.cs
- InputLanguageCollection.cs
- WebPartManagerDesigner.cs
- SqlCacheDependency.cs
- XmlKeywords.cs
- WindowsSolidBrush.cs
- EnumMemberAttribute.cs
- ProfileManager.cs
- DBBindings.cs
- FirstMatchCodeGroup.cs
- ErrorInfoXmlDocument.cs
- JsonFormatGeneratorStatics.cs
- ValueSerializer.cs
- WsatServiceAddress.cs
- smtpconnection.cs
- SecurityIdentifierElement.cs
- StreamingContext.cs
- ToolTipAutomationPeer.cs
- TriState.cs
- WebControlAdapter.cs
- Drawing.cs
- ColorDialog.cs
- ThicknessAnimationBase.cs
- XPathExpr.cs
- StsCommunicationException.cs
- ControlCachePolicy.cs
- WorkflowInvoker.cs
- WebServiceClientProxyGenerator.cs
- ItemCheckEvent.cs
- PeerContact.cs
- ByteStreamGeometryContext.cs
- BitmapEffectInputData.cs
- FontInfo.cs
- SqlTrackingService.cs
- CodeAttributeDeclarationCollection.cs
- BamlReader.cs
- GenericTypeParameterConverter.cs
- DigestComparer.cs
- KeyboardInputProviderAcquireFocusEventArgs.cs
- PopupControlService.cs
- MarkerProperties.cs
- ConnectionPointCookie.cs
- AutoScrollExpandMessageFilter.cs
- WbemException.cs
- AddInSegmentDirectoryNotFoundException.cs
- Color.cs
- DirectoryNotFoundException.cs
- DesignerAttribute.cs
- PerformanceCounterManager.cs
- Grant.cs
- Expression.cs
- PageThemeParser.cs
- ClientTarget.cs
- StreamGeometry.cs
- XmlCharacterData.cs
- ClaimTypeRequirement.cs
- Label.cs
- AmbientLight.cs
- PanelContainerDesigner.cs
- HttpRuntime.cs
- RefExpr.cs
- ChildTable.cs
- RectangleGeometry.cs
- AddInIpcChannel.cs
- FrameworkTextComposition.cs
- TableLayout.cs
- OrderedDictionary.cs
- EventMemberCodeDomSerializer.cs
- SiteMapNodeItem.cs
- TagNameToTypeMapper.cs
- _FtpDataStream.cs
- PageAsyncTask.cs
- Baml2006ReaderSettings.cs