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
- ToolStripArrowRenderEventArgs.cs
- FullTextState.cs
- PreservationFileWriter.cs
- TextServicesManager.cs
- ObjectDataSourceView.cs
- HtmlButton.cs
- SocketInformation.cs
- UnsafeNativeMethods.cs
- DoubleLinkList.cs
- CompilerError.cs
- ManualResetEvent.cs
- Missing.cs
- SystemMulticastIPAddressInformation.cs
- DataBindingList.cs
- SubclassTypeValidatorAttribute.cs
- SimpleRecyclingCache.cs
- PointF.cs
- Vector.cs
- SerializerWriterEventHandlers.cs
- ToolStrip.cs
- XLinq.cs
- ConsumerConnectionPoint.cs
- XmlSchemaValidationException.cs
- _UriSyntax.cs
- FixedFlowMap.cs
- IOException.cs
- _ProxyChain.cs
- VideoDrawing.cs
- FilteredXmlReader.cs
- SoapElementAttribute.cs
- JoinTreeNode.cs
- HostVisual.cs
- SqlCommand.cs
- ListChangedEventArgs.cs
- DataConnectionHelper.cs
- ToolStripItemTextRenderEventArgs.cs
- CommandPlan.cs
- SimpleTypeResolver.cs
- FileUtil.cs
- GridProviderWrapper.cs
- OleAutBinder.cs
- IriParsingElement.cs
- HttpCapabilitiesEvaluator.cs
- NonParentingControl.cs
- FieldBuilder.cs
- PeerObject.cs
- FloaterParaClient.cs
- SizeAnimationBase.cs
- DataObjectSettingDataEventArgs.cs
- MenuItem.cs
- ControlParameter.cs
- FeatureSupport.cs
- PreloadedPackages.cs
- ToolStripPanelCell.cs
- WebServicesInteroperability.cs
- ResponseBodyWriter.cs
- DataGridComboBoxColumn.cs
- SqlFormatter.cs
- ImageMapEventArgs.cs
- Deflater.cs
- ScrollViewerAutomationPeer.cs
- SessionEndingCancelEventArgs.cs
- DocumentViewerBase.cs
- PeerTransportCredentialType.cs
- PrintEvent.cs
- PeerApplicationLaunchInfo.cs
- PropertyBuilder.cs
- ColumnWidthChangingEvent.cs
- TextViewDesigner.cs
- ServiceHttpModule.cs
- TdsRecordBufferSetter.cs
- Wildcard.cs
- _TransmitFileOverlappedAsyncResult.cs
- UserInitiatedNavigationPermission.cs
- CategoryEditor.cs
- ProxyHelper.cs
- ElapsedEventArgs.cs
- FontUnit.cs
- VectorCollectionValueSerializer.cs
- ClusterRegistryConfigurationProvider.cs
- XamlWriter.cs
- ExpressionPrefixAttribute.cs
- Evidence.cs
- AnnotationComponentChooser.cs
- StringComparer.cs
- TTSVoice.cs
- OutputCacheProfileCollection.cs
- SqlFunctionAttribute.cs
- SqlNotificationEventArgs.cs
- SqlParameterCollection.cs
- Light.cs
- TextDpi.cs
- DependencyObjectProvider.cs
- EntityViewGenerationConstants.cs
- ObjectDataSourceSelectingEventArgs.cs
- MimeMapping.cs
- Utility.cs
- DragAssistanceManager.cs
- SrgsText.cs
- DocumentManager.cs