Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / QueryOperators / ListQueryResults.cs / 1305376 / ListQueryResults.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // ListQueryResults.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Collections.Generic; namespace System.Linq.Parallel { ////// Class to represent an IList{T} as QueryResults{T} /// ///internal class ListQueryResults : QueryResults { private IList m_source; private int m_partitionCount; private bool m_useStriping; internal ListQueryResults(IList source, int partitionCount, bool useStriping) { m_source = source; m_partitionCount = partitionCount; m_useStriping = useStriping; } internal override void GivePartitionedStream(IPartitionedStreamRecipient recipient) { PartitionedStream partitionedStream = GetPartitionedStream(); recipient.Receive (partitionedStream); } internal override bool IsIndexible { get { return true; } } internal override int ElementsCount { get { return m_source.Count; } } internal override T GetElement(int index) { return m_source[index]; } internal PartitionedStream GetPartitionedStream() { return ExchangeUtilities.PartitionDataSource(m_source, m_partitionCount, m_useStriping); } } } // 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
- PipeStream.cs
- PropertyValue.cs
- TextEndOfSegment.cs
- EventEntry.cs
- MarkupExtensionParser.cs
- RijndaelManagedTransform.cs
- ButtonPopupAdapter.cs
- VisualStyleInformation.cs
- InternalBufferOverflowException.cs
- SyndicationCategory.cs
- DetectEofStream.cs
- EndpointAddressAugust2004.cs
- MachinePropertyVariants.cs
- ToolboxBitmapAttribute.cs
- ProcessProtocolHandler.cs
- CodeMemberField.cs
- SaveFileDialog.cs
- DataTemplateSelector.cs
- SizeValueSerializer.cs
- InputManager.cs
- StringCollection.cs
- EntitySetBaseCollection.cs
- ColumnCollection.cs
- Internal.cs
- WindowsTooltip.cs
- CoreSwitches.cs
- TableStyle.cs
- SocketAddress.cs
- XmlSchemaSimpleType.cs
- QueryOutputWriter.cs
- MenuItem.cs
- ColorAnimationBase.cs
- TcpStreams.cs
- SchemaImporter.cs
- SafeNativeMethods.cs
- BufferedGraphicsManager.cs
- LinkDesigner.cs
- versioninfo.cs
- BaseParaClient.cs
- WebPartHeaderCloseVerb.cs
- HwndAppCommandInputProvider.cs
- ProviderConnectionPoint.cs
- AnnotationService.cs
- DiffuseMaterial.cs
- MulticastNotSupportedException.cs
- SeekStoryboard.cs
- XamlTypeMapperSchemaContext.cs
- EntitySqlException.cs
- NativeRecognizer.cs
- ColorConvertedBitmapExtension.cs
- ExpressionBuilderCollection.cs
- XpsDigitalSignature.cs
- SimpleExpression.cs
- VariantWrapper.cs
- SmiGettersStream.cs
- TypefaceMap.cs
- OdbcConnectionPoolProviderInfo.cs
- AnnotationHelper.cs
- XdrBuilder.cs
- AddingNewEventArgs.cs
- ExpandSegment.cs
- ToolTipService.cs
- LocationSectionRecord.cs
- SignatureDescription.cs
- NameScope.cs
- StickyNoteHelper.cs
- SqlFunctionAttribute.cs
- HtmlImageAdapter.cs
- FamilyCollection.cs
- ListControlDesigner.cs
- DesignerActionHeaderItem.cs
- DocumentApplicationJournalEntryEventArgs.cs
- BaseConfigurationRecord.cs
- TreeView.cs
- WebReferenceOptions.cs
- StandardBindingElementCollection.cs
- ToolStripSplitStackLayout.cs
- DesignBindingValueUIHandler.cs
- CommonDialog.cs
- SinglePageViewer.cs
- XsdDataContractExporter.cs
- HtmlInputSubmit.cs
- DBCSCodePageEncoding.cs
- ListParaClient.cs
- DataTableReaderListener.cs
- ExceptionUtil.cs
- DataTable.cs
- ClassImporter.cs
- DateTimeFormatInfoScanner.cs
- ListBox.cs
- BufferedWebEventProvider.cs
- FixedHyperLink.cs
- BamlRecords.cs
- DesignSurfaceManager.cs
- ParseNumbers.cs
- PageOutputColor.cs
- Touch.cs
- DataGridViewRow.cs
- Helpers.cs
- ObjectManager.cs