Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / Partitioning / OrderedHashRepartitionStream.cs / 1305376 / OrderedHashRepartitionStream.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // OrderedHashRepartitionStream.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections.Generic; using System.Threading; namespace System.Linq.Parallel { internal class OrderedHashRepartitionStream: HashRepartitionStream { internal OrderedHashRepartitionStream( PartitionedStream inputStream, Func hashKeySelector, IEqualityComparer hashKeyComparer, IEqualityComparer elementComparer, CancellationToken cancellationToken) : base(inputStream.PartitionCount, inputStream.KeyComparer, hashKeyComparer, elementComparer) { m_partitions = new OrderedHashRepartitionEnumerator [inputStream.PartitionCount]; // Initialize state shared among the partitions. A latch and a matrix of buffers. Note that // the actual elements in the buffer array are lazily allocated if needed. CountdownEvent barrier = new CountdownEvent(inputStream.PartitionCount); ListChunk >[,] valueExchangeMatrix = new ListChunk >[inputStream.PartitionCount, inputStream.PartitionCount]; ListChunk [,] keyExchangeMatrix = new ListChunk [inputStream.PartitionCount, inputStream.PartitionCount]; // Now construct each partition object. for (int i = 0; i < inputStream.PartitionCount; i++) { m_partitions[i] = new OrderedHashRepartitionEnumerator ( inputStream[i], inputStream.PartitionCount, i, hashKeySelector, this, barrier, valueExchangeMatrix, keyExchangeMatrix, cancellationToken); } } } } // 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
- EntryWrittenEventArgs.cs
- FontFamily.cs
- JoinElimination.cs
- RootBrowserWindowAutomationPeer.cs
- ResponseBodyWriter.cs
- TraceHandlerErrorFormatter.cs
- mda.cs
- BitArray.cs
- FixUpCollection.cs
- baseaxisquery.cs
- StringOutput.cs
- ScaleTransform3D.cs
- ComponentConverter.cs
- FindResponse.cs
- CodeTypeParameter.cs
- Pens.cs
- InvokeHandlers.cs
- ControlEvent.cs
- Triangle.cs
- LinkClickEvent.cs
- CodeChecksumPragma.cs
- FileClassifier.cs
- ContractInferenceHelper.cs
- OneOf.cs
- ListViewItem.cs
- OleDbParameterCollection.cs
- PlatformCulture.cs
- KernelTypeValidation.cs
- ViewManager.cs
- AdRotator.cs
- DefaultParameterValueAttribute.cs
- WmfPlaceableFileHeader.cs
- Pen.cs
- ObfuscationAttribute.cs
- HtmlShim.cs
- SecurityState.cs
- ListItemCollection.cs
- FeatureAttribute.cs
- XmlDocumentViewSchema.cs
- XmlBinaryReaderSession.cs
- Sql8ExpressionRewriter.cs
- DecoderNLS.cs
- CanExecuteRoutedEventArgs.cs
- NonSerializedAttribute.cs
- PenLineCapValidation.cs
- BaseTreeIterator.cs
- ConnectionAcceptor.cs
- CdpEqualityComparer.cs
- ColorContextHelper.cs
- ServiceEndpointElementCollection.cs
- NativeMethods.cs
- HandlerFactoryWrapper.cs
- SafeLocalMemHandle.cs
- DataViewListener.cs
- UriWriter.cs
- CompModSwitches.cs
- AnonymousIdentificationSection.cs
- DataPointer.cs
- TimeoutValidationAttribute.cs
- ClickablePoint.cs
- TemplateLookupAction.cs
- SafeProcessHandle.cs
- InvokeBinder.cs
- DocumentViewerBaseAutomationPeer.cs
- StringOutput.cs
- ISFClipboardData.cs
- DesignTimeTemplateParser.cs
- TileModeValidation.cs
- FormsAuthenticationModule.cs
- HwndHostAutomationPeer.cs
- ActiveXHelper.cs
- Compiler.cs
- ConfigurationLocationCollection.cs
- _SslSessionsCache.cs
- CompoundFileStorageReference.cs
- NavigationProperty.cs
- HtmlGenericControl.cs
- DefaultObjectMappingItemCollection.cs
- PeerNearMe.cs
- CheckBox.cs
- MetafileHeaderWmf.cs
- DbConnectionFactory.cs
- EventLogPermissionEntryCollection.cs
- PointValueSerializer.cs
- QualificationDataItem.cs
- DbDataRecord.cs
- path.cs
- StringAttributeCollection.cs
- RequestCacheEntry.cs
- AnonymousIdentificationSection.cs
- TypeUtil.cs
- BamlBinaryWriter.cs
- Aggregates.cs
- LowerCaseStringConverter.cs
- PeerDefaultCustomResolverClient.cs
- FactoryRecord.cs
- NameValuePermission.cs
- AvTrace.cs
- RadioButtonFlatAdapter.cs
- LocalizationParserHooks.cs