Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / Inlined / DecimalSumAggregationOperator.cs / 1305376 / DecimalSumAggregationOperator.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // DecimalSumAggregationOperator.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections.Generic; using System.Diagnostics.Contracts; using System.Threading; namespace System.Linq.Parallel { ////// An inlined sum aggregation and its enumerator, for decimals. /// internal sealed class DecimalSumAggregationOperator : InlinedAggregationOperator{ //---------------------------------------------------------------------------------------- // Constructs a new instance of a sum associative operator. // internal DecimalSumAggregationOperator(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 decimal 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. decimal sum = 0.0m; while (enumerator.MoveNext()) { 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 DecimalSumAggregationOperatorEnumerator (source, index, cancellationToken); } //--------------------------------------------------------------------------------------- // This enumerator type encapsulates the intermediary aggregation over the underlying // (possibly partitioned) data source. // private class DecimalSumAggregationOperatorEnumerator : InlinedAggregationOperatorEnumerator { private QueryOperatorEnumerator m_source; // The source data. //---------------------------------------------------------------------------------------- // Instantiates a new aggregation operator. // internal DecimalSumAggregationOperatorEnumerator(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 decimal currentElement) { decimal element = default(decimal); 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. decimal tempSum = 0.0m; int i = 0; do { if ((i++ & CancellationState.POLL_INTERVAL) == 0) CancellationState.ThrowIfCanceled(m_cancellationToken); 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
- LexicalChunk.cs
- OrderPreservingSpoolingTask.cs
- GridViewColumnHeaderAutomationPeer.cs
- FtpCachePolicyElement.cs
- CodeDefaultValueExpression.cs
- BaseParagraph.cs
- SystemIPAddressInformation.cs
- Attributes.cs
- HelpProvider.cs
- localization.cs
- SqlMethodTransformer.cs
- EntityViewGenerationAttribute.cs
- BackgroundWorker.cs
- WebHttpEndpoint.cs
- Int32Storage.cs
- NonBatchDirectoryCompiler.cs
- Number.cs
- RestHandler.cs
- ArcSegment.cs
- JsonReaderDelegator.cs
- HeaderCollection.cs
- FileDialog_Vista.cs
- AppDomain.cs
- GPStream.cs
- BrowserCapabilitiesFactory.cs
- Vector.cs
- DictionaryBase.cs
- Utilities.cs
- ObjectListShowCommandsEventArgs.cs
- AuthenticatingEventArgs.cs
- SymmetricAlgorithm.cs
- NumberFunctions.cs
- PathSegmentCollection.cs
- MessageQueuePermissionAttribute.cs
- InsufficientMemoryException.cs
- ObjectStateFormatter.cs
- PkcsUtils.cs
- TraceHelpers.cs
- ComponentChangedEvent.cs
- HttpCookieCollection.cs
- CodeAttachEventStatement.cs
- RecordConverter.cs
- MemberMaps.cs
- ListMarkerLine.cs
- CompoundFileReference.cs
- EncoderBestFitFallback.cs
- UpdateException.cs
- HtmlInputRadioButton.cs
- KnownColorTable.cs
- ExpandableObjectConverter.cs
- CapabilitiesUse.cs
- NonDualMessageSecurityOverHttpElement.cs
- Point3DCollectionConverter.cs
- MaskedTextBox.cs
- InvalidFilterCriteriaException.cs
- AutomationPropertyInfo.cs
- IssuedSecurityTokenProvider.cs
- TextAdaptor.cs
- XmlChildEnumerator.cs
- DependencyObjectCodeDomSerializer.cs
- AssemblyHelper.cs
- Misc.cs
- DelegatingTypeDescriptionProvider.cs
- UserControlBuildProvider.cs
- ToolStripItem.cs
- WhereaboutsReader.cs
- PropertyMap.cs
- OdbcConnectionPoolProviderInfo.cs
- RegexRunnerFactory.cs
- GroupBoxDesigner.cs
- CqlQuery.cs
- RubberbandSelector.cs
- ListBoxItem.cs
- GridViewCellAutomationPeer.cs
- AutomationElement.cs
- DecimalStorage.cs
- FileSystemEventArgs.cs
- PolicyManager.cs
- PathFigureCollection.cs
- X509AudioLogo.cs
- DeploymentSectionCache.cs
- HybridObjectCache.cs
- SmtpFailedRecipientsException.cs
- FtpRequestCacheValidator.cs
- Certificate.cs
- DocumentReferenceCollection.cs
- Polyline.cs
- RemoteHelper.cs
- MethodBuilderInstantiation.cs
- NodeLabelEditEvent.cs
- smtpconnection.cs
- Scheduler.cs
- StateDesigner.cs
- SettingsPropertyIsReadOnlyException.cs
- NativeRightsManagementAPIsStructures.cs
- DynamicHyperLink.cs
- GacUtil.cs
- ZipIOLocalFileBlock.cs
- DesignTimeType.cs
- FixedDSBuilder.cs