Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / Inlined / NullableFloatSumAggregationOperator.cs / 1305376 / NullableFloatSumAggregationOperator.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // NullableFloatSumAggregationOperator.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections.Generic; using System.Diagnostics.Contracts; using System.Threading; namespace System.Linq.Parallel { ////// An inlined sum aggregation and its enumerator, for Nullable floats. /// internal sealed class NullableFloatSumAggregationOperator : InlinedAggregationOperator{ //---------------------------------------------------------------------------------------- // Constructs a new instance of a sum associative operator. // internal NullableFloatSumAggregationOperator(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 float? 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. double sum = 0.0f; while (enumerator.MoveNext()) { sum += enumerator.Current.GetValueOrDefault(); } return (float)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 NullableFloatSumAggregationOperatorEnumerator (source, index, cancellationToken); } //--------------------------------------------------------------------------------------- // This enumerator type encapsulates the intermediary aggregation over the underlying // (possibly partitioned) data source. // private class NullableFloatSumAggregationOperatorEnumerator : InlinedAggregationOperatorEnumerator { private readonly QueryOperatorEnumerator m_source; // The source data. //---------------------------------------------------------------------------------------- // Instantiates a new aggregation operator. // internal NullableFloatSumAggregationOperatorEnumerator(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 double? currentElement) { float? element = default(float?); 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. float tempSum = 0.0f; int i = 0; do { if ((i++ & CancellationState.POLL_INTERVAL) == 0) CancellationState.ThrowIfCanceled(m_cancellationToken); tempSum += element.GetValueOrDefault(); } while (source.MoveNext(ref element, ref keyUnused)); // The sum has been calculated. Now just return. currentElement = new double?(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
- WebServiceClientProxyGenerator.cs
- CustomErrorCollection.cs
- XmlIterators.cs
- SqlDataReader.cs
- OlePropertyStructs.cs
- PixelShader.cs
- SecurityTokenTypes.cs
- Hex.cs
- WebProxyScriptElement.cs
- AdornerLayer.cs
- EntityDataSourceView.cs
- NetworkInterface.cs
- XmlSchemas.cs
- ConnectionManagementElementCollection.cs
- CompensatableTransactionScopeActivityDesigner.cs
- ColorAnimation.cs
- PropertyChangedEventManager.cs
- FilterQuery.cs
- PropertyFilterAttribute.cs
- TreeIterator.cs
- AmbiguousMatchException.cs
- TimeSpanConverter.cs
- ModuleBuilder.cs
- PeerInputChannel.cs
- BuildDependencySet.cs
- RequestTimeoutManager.cs
- DynamicControlParameter.cs
- CqlParserHelpers.cs
- HttpBufferlessInputStream.cs
- ChtmlLinkAdapter.cs
- HttpHandlersSection.cs
- ExpressionEvaluator.cs
- DetailsView.cs
- CapiSafeHandles.cs
- XmlSchemaComplexContentExtension.cs
- Config.cs
- TokenBasedSet.cs
- TableCell.cs
- ConfigurationElement.cs
- Membership.cs
- ConfigurationElementCollection.cs
- hresults.cs
- XmlSchemaIdentityConstraint.cs
- LinqDataSource.cs
- Bookmark.cs
- dbdatarecord.cs
- RegisteredExpandoAttribute.cs
- RecordManager.cs
- SaveLedgerEntryRequest.cs
- DataControlFieldHeaderCell.cs
- DataControlImageButton.cs
- TrackBarDesigner.cs
- StrokeIntersection.cs
- ConnectionsZone.cs
- TextModifierScope.cs
- TargetPerspective.cs
- CaseInsensitiveOrdinalStringComparer.cs
- BindingNavigator.cs
- KeyTimeConverter.cs
- MediaElement.cs
- ExpressionSelection.cs
- BindingExpressionUncommonField.cs
- InkCollectionBehavior.cs
- DocumentGrid.cs
- DirectoryInfo.cs
- DecodeHelper.cs
- UIElementPropertyUndoUnit.cs
- Light.cs
- BoolExpression.cs
- LexicalChunk.cs
- NetSectionGroup.cs
- XmlSchemas.cs
- WithParamAction.cs
- CustomBinding.cs
- CallContext.cs
- ShaperBuffers.cs
- TimerElapsedEvenArgs.cs
- PropertyDescriptorCollection.cs
- XmlAnyElementAttribute.cs
- XmlHelper.cs
- X509CertificateTokenFactoryCredential.cs
- SessionParameter.cs
- SHA384CryptoServiceProvider.cs
- DummyDataSource.cs
- WhitespaceReader.cs
- MemoryFailPoint.cs
- JsonWriterDelegator.cs
- RotateTransform.cs
- DataSetViewSchema.cs
- XamlTreeBuilderBamlRecordWriter.cs
- UntypedNullExpression.cs
- SamlAudienceRestrictionCondition.cs
- HtmlHistory.cs
- QueryConverter.cs
- RegexReplacement.cs
- HopperCache.cs
- UriScheme.cs
- CompositionAdorner.cs
- TableCellCollection.cs
- CustomWebEventKey.cs