Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Core / System / Linq / Parallel / Scheduling / QueryTask.cs / 1305376 / QueryTask.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== // =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+ // // QueryTask.cs // //[....] // // =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=- using System.Threading; using System.Threading.Tasks; using System.Diagnostics.Contracts; namespace System.Linq.Parallel { // To disable exception marshaling (e.g. for debugging purposes), uncomment this symbol // or recompile PLINQ passing the symbol on the cmd-line, i.e. csc.exe ... /d:LET_... //#define LET_ASYNC_EXCEPTIONS_CRASH ////// Simple abstract task representation, allowing either synchronous and asynchronous /// execution. Subclasses override the Work API to implement the logic. /// internal abstract class QueryTask { protected int m_taskIndex; // The unique id of this task. protected QueryTaskGroupState m_groupState; // State shared among the tasks. //------------------------------------------------------------------------------------ // Constructs a new task with the specified shared state. // protected QueryTask(int taskIndex, QueryTaskGroupState groupState) { Contract.Assert(groupState != null); m_taskIndex = taskIndex; m_groupState = groupState; } //----------------------------------------------------------------------------------- // A static function used by s_runTaskSynchronouslyDelegate, which is used by RunSynchronously // private static void RunTaskSynchronously(object o) { ((QueryTask)o).BaseWork(null); } //----------------------------------------------------------------------------------- // A static delegate used by RunSynchronously // private static Action
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- AttachmentCollection.cs
- CodeTypeReference.cs
- WindowsClientCredential.cs
- StateInitialization.cs
- Bind.cs
- FixedPosition.cs
- Ops.cs
- messageonlyhwndwrapper.cs
- XmlChildEnumerator.cs
- CompilationUnit.cs
- ProfileEventArgs.cs
- RegistrationServices.cs
- MouseDevice.cs
- SafeRightsManagementPubHandle.cs
- Wildcard.cs
- TextStore.cs
- DataGridCommandEventArgs.cs
- AutoGeneratedFieldProperties.cs
- XmlSchemaSimpleContentRestriction.cs
- Attributes.cs
- IncomingWebResponseContext.cs
- ScrollEvent.cs
- ContractTypeNameElement.cs
- SoapSchemaImporter.cs
- CharacterBuffer.cs
- QuotaThrottle.cs
- RtfToXamlLexer.cs
- SqlUserDefinedAggregateAttribute.cs
- QuaternionIndependentAnimationStorage.cs
- Overlapped.cs
- WebBrowserContainer.cs
- UniqueID.cs
- ActivityIdHeader.cs
- LinkClickEvent.cs
- HttpProtocolImporter.cs
- UserControlBuildProvider.cs
- StorageEndPropertyMapping.cs
- XmlSchemas.cs
- SpotLight.cs
- ManipulationCompletedEventArgs.cs
- ItemList.cs
- RuntimeWrappedException.cs
- IndentTextWriter.cs
- AllMembershipCondition.cs
- PersonalizablePropertyEntry.cs
- ToolboxComponentsCreatedEventArgs.cs
- ExclusiveHandle.cs
- ArcSegment.cs
- RemoteWebConfigurationHostStream.cs
- BitmapFrameEncode.cs
- BookmarkUndoUnit.cs
- FieldNameLookup.cs
- WebPartCancelEventArgs.cs
- ScopelessEnumAttribute.cs
- PrimitiveList.cs
- _IPv6Address.cs
- XPathBuilder.cs
- AuthenticationModuleElement.cs
- ListenerAdapterBase.cs
- InstanceContextMode.cs
- UnsafeNativeMethods.cs
- BamlLocalizableResourceKey.cs
- TdsParserStateObject.cs
- SchemaTypeEmitter.cs
- GradientBrush.cs
- baseaxisquery.cs
- ContainerParagraph.cs
- CheckBoxRenderer.cs
- dataobject.cs
- PipeException.cs
- WmlPanelAdapter.cs
- QilName.cs
- NullableDoubleSumAggregationOperator.cs
- MaterializeFromAtom.cs
- TimeManager.cs
- AdapterDictionary.cs
- QilReplaceVisitor.cs
- COM2IDispatchConverter.cs
- MasterPageCodeDomTreeGenerator.cs
- CompilerInfo.cs
- HtmlGenericControl.cs
- PropertyCollection.cs
- ClientConfigurationSystem.cs
- ObjectDataSourceFilteringEventArgs.cs
- SessionMode.cs
- FtpWebResponse.cs
- ByteAnimationBase.cs
- SQLDoubleStorage.cs
- HttpContextServiceHost.cs
- TextClipboardData.cs
- FileVersion.cs
- CachedTypeface.cs
- EntityDataSourceReferenceGroup.cs
- JsonReader.cs
- StylusPointPropertyInfo.cs
- JoinCqlBlock.cs
- QilBinary.cs
- BackStopAuthenticationModule.cs
- DataReaderContainer.cs
- DESCryptoServiceProvider.cs