Code:
/ 4.0 / 4.0 / 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. // ==++== // // 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
- SQLInt64Storage.cs
- SiteMapDataSource.cs
- DiagnosticTraceSource.cs
- TagMapInfo.cs
- ClearCollection.cs
- HTTPRemotingHandler.cs
- ListControlConvertEventArgs.cs
- DiscoveryClientChannelFactory.cs
- ToolboxItemFilterAttribute.cs
- Unit.cs
- DataGridViewSelectedColumnCollection.cs
- EasingQuaternionKeyFrame.cs
- SingleStorage.cs
- EventDescriptorCollection.cs
- QueueProcessor.cs
- EntityDataSourceSelectingEventArgs.cs
- ServiceModelEnumValidator.cs
- SqlCachedBuffer.cs
- IsolatedStorage.cs
- ImportStoreException.cs
- Compiler.cs
- GradientPanel.cs
- SrgsElementList.cs
- MailAddressCollection.cs
- XmlNotation.cs
- PrimitiveCodeDomSerializer.cs
- CacheModeConverter.cs
- StylusPointPropertyInfo.cs
- DnsPermission.cs
- TargetFrameworkUtil.cs
- CriticalFinalizerObject.cs
- TableCellCollection.cs
- metadatamappinghashervisitor.cs
- ViewGenerator.cs
- FixedPosition.cs
- TemplateManager.cs
- MetadataArtifactLoader.cs
- ImageKeyConverter.cs
- BinaryObjectWriter.cs
- UnitySerializationHolder.cs
- TemplateComponentConnector.cs
- ResourceReferenceKeyNotFoundException.cs
- PackageStore.cs
- LinearKeyFrames.cs
- ConnectorSelectionGlyph.cs
- DataGridViewCell.cs
- MetadataPropertyvalue.cs
- TabControl.cs
- DataReceivedEventArgs.cs
- CodeMemberProperty.cs
- MenuItemCollection.cs
- iisPickupDirectory.cs
- SafeNativeMethodsCLR.cs
- TdsParser.cs
- RoleServiceManager.cs
- ReaderWriterLock.cs
- SessionEndingCancelEventArgs.cs
- RulePatternOps.cs
- SystemIdentity.cs
- TreeNodeStyle.cs
- DataPagerCommandEventArgs.cs
- SqlProfileProvider.cs
- OrderingExpression.cs
- DataGridColumnEventArgs.cs
- ValidationManager.cs
- DataRowExtensions.cs
- ColorTransformHelper.cs
- StaticSiteMapProvider.cs
- PathTooLongException.cs
- FlowDocumentFormatter.cs
- GetTokenRequest.cs
- ClassGenerator.cs
- FaultContext.cs
- CacheChildrenQuery.cs
- ExpressionPrinter.cs
- SortedList.cs
- WorkflowItemPresenter.cs
- CodePrimitiveExpression.cs
- PresentationSource.cs
- CallInfo.cs
- ConstNode.cs
- TableLayoutCellPaintEventArgs.cs
- CellNormalizer.cs
- EntryIndex.cs
- MatrixConverter.cs
- ToolStripItemClickedEventArgs.cs
- FixedHyperLink.cs
- XmlWrappingReader.cs
- DateTimeConverter.cs
- QueryStringParameter.cs
- WebPartDescriptionCollection.cs
- DataGridViewMethods.cs
- WebResponse.cs
- Int32KeyFrameCollection.cs
- EllipseGeometry.cs
- PolicyDesigner.cs
- WebPartEditorCancelVerb.cs
- COM2PictureConverter.cs
- ScriptBehaviorDescriptor.cs
- PropertyChangingEventArgs.cs