Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / ndp / clr / src / BCL / System / Threading / Monitor.cs / 1 / Monitor.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== /*============================================================================== ** ** Class: Monitor ** ** ** Purpose: Synchronizes access to a shared resource or region of code in a multi-threaded ** program. ** ** =============================================================================*/ namespace System.Threading { using System; using System.Security.Permissions; using System.Runtime.Remoting; using System.Threading; using System.Runtime.CompilerServices; using System.Runtime.ConstrainedExecution; [HostProtection(Synchronization=true, ExternalThreading=true)] [System.Runtime.InteropServices.ComVisible(true)] public static class Monitor { /*========================================================================= ** Obtain the monitor lock of obj. Will block if another thread holds the lock ** Will not block if the current thread holds the lock, ** however the caller must ensure that the same number of Exit ** calls are made as there were Enter calls. ** ** Exceptions: ArgumentNullException if object is null. =========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] public static extern void Enter(Object obj); // This should be made public in a future version. // Use a ref bool instead of out to ensure that unverifiable code must // initialize this value to something. If we used out, the value // could be uninitialized if we threw an exception in our prolog. [MethodImplAttribute(MethodImplOptions.InternalCall)] internal static extern void ReliableEnter(Object obj, ref bool tookLock); /*========================================================================= ** Release the monitor lock. If one or more threads are waiting to acquire the ** lock, and the current thread has executed as many Exits as ** Enters, one of the threads will be unblocked and allowed to proceed. ** ** Exceptions: ArgumentNullException if object is null. ** SynchronizationLockException if the current thread does not ** own the lock. =========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] [ReliabilityContract(Consistency.WillNotCorruptState, Cer.Success)] public static extern void Exit(Object obj); /*========================================================================= ** Similar to Enter, but will never block. That is, if the current thread can ** acquire the monitor lock without blocking, it will do so and TRUE will ** be returned. Otherwise FALSE will be returned. ** ** Exceptions: ArgumentNullException if object is null. =========================================================================*/ public static bool TryEnter(Object obj) { return TryEnterTimeout(obj, 0); } /*========================================================================== ** Version of TryEnter that will block, but only up to a timeout period ** expressed in milliseconds. If timeout == Timeout.Infinite the method ** becomes equivalent to Enter. ** ** Exceptions: ArgumentNullException if object is null. ** ArgumentException if timeout < 0. =========================================================================*/ public static bool TryEnter(Object obj, int millisecondsTimeout) { return TryEnterTimeout(obj, millisecondsTimeout); } public static bool TryEnter(Object obj, TimeSpan timeout) { long tm = (long)timeout.TotalMilliseconds; if (tm < -1 || tm > (long) Int32.MaxValue) throw new ArgumentOutOfRangeException("timeout", Environment.GetResourceString("ArgumentOutOfRange_NeedNonNegOrNegative1")); return TryEnterTimeout(obj, (int)tm); } [MethodImplAttribute(MethodImplOptions.InternalCall)] private static extern bool TryEnterTimeout(Object obj, int timeout); /*======================================================================= ** Waits for notification from the object (via a Pulse/PulseAll). ** timeout indicates how long to wait before the method returns. ** This method acquires the monitor waithandle for the object ** If this thread holds the monitor lock for the object, it releases it. ** On exit from the method, it obtains the monitor lock back. ** If exitContext is true then the synchronization domain for the context ** (if in a synchronized context) is exited before the wait and reacquired ** ** Exceptions: ArgumentNullException if object is null. ========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] private static extern bool ObjWait(bool exitContext, int millisecondsTimeout,Object obj); public static bool Wait(Object obj, int millisecondsTimeout, bool exitContext) { if (obj == null) throw (new ArgumentNullException("obj")); return ObjWait(exitContext, millisecondsTimeout, obj); } public static bool Wait(Object obj, TimeSpan timeout, bool exitContext) { long tm = (long)timeout.TotalMilliseconds; if (tm < -1 || tm > (long) Int32.MaxValue) throw new ArgumentOutOfRangeException("timeout", Environment.GetResourceString("ArgumentOutOfRange_NeedNonNegOrNegative1")); return Wait(obj, (int)tm, exitContext); } public static bool Wait(Object obj, int millisecondsTimeout) { return Wait(obj,millisecondsTimeout,false); } public static bool Wait(Object obj, TimeSpan timeout) { long tm = (long)timeout.TotalMilliseconds; if (tm < -1 || tm > (long) Int32.MaxValue) throw new ArgumentOutOfRangeException("timeout", Environment.GetResourceString("ArgumentOutOfRange_NeedNonNegOrNegative1")); return Wait(obj,(int)tm,false); } public static bool Wait(Object obj) { return Wait(obj,Timeout.Infinite,false); } /*======================================================================== ** Sends a notification to a single waiting object. * Exceptions: SynchronizationLockException if this method is not called inside * a synchronized block of code. ========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] private static extern void ObjPulse(Object obj); public static void Pulse(Object obj) { if (obj==null) { throw new ArgumentNullException("obj"); } ObjPulse(obj); } /*======================================================================== ** Sends a notification to all waiting objects. ========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] private static extern void ObjPulseAll(Object obj); public static void PulseAll(Object obj) { if (obj==null) { throw new ArgumentNullException("obj"); } ObjPulseAll(obj); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== /*============================================================================== ** ** Class: Monitor ** ** ** Purpose: Synchronizes access to a shared resource or region of code in a multi-threaded ** program. ** ** =============================================================================*/ namespace System.Threading { using System; using System.Security.Permissions; using System.Runtime.Remoting; using System.Threading; using System.Runtime.CompilerServices; using System.Runtime.ConstrainedExecution; [HostProtection(Synchronization=true, ExternalThreading=true)] [System.Runtime.InteropServices.ComVisible(true)] public static class Monitor { /*========================================================================= ** Obtain the monitor lock of obj. Will block if another thread holds the lock ** Will not block if the current thread holds the lock, ** however the caller must ensure that the same number of Exit ** calls are made as there were Enter calls. ** ** Exceptions: ArgumentNullException if object is null. =========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] public static extern void Enter(Object obj); // This should be made public in a future version. // Use a ref bool instead of out to ensure that unverifiable code must // initialize this value to something. If we used out, the value // could be uninitialized if we threw an exception in our prolog. [MethodImplAttribute(MethodImplOptions.InternalCall)] internal static extern void ReliableEnter(Object obj, ref bool tookLock); /*========================================================================= ** Release the monitor lock. If one or more threads are waiting to acquire the ** lock, and the current thread has executed as many Exits as ** Enters, one of the threads will be unblocked and allowed to proceed. ** ** Exceptions: ArgumentNullException if object is null. ** SynchronizationLockException if the current thread does not ** own the lock. =========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] [ReliabilityContract(Consistency.WillNotCorruptState, Cer.Success)] public static extern void Exit(Object obj); /*========================================================================= ** Similar to Enter, but will never block. That is, if the current thread can ** acquire the monitor lock without blocking, it will do so and TRUE will ** be returned. Otherwise FALSE will be returned. ** ** Exceptions: ArgumentNullException if object is null. =========================================================================*/ public static bool TryEnter(Object obj) { return TryEnterTimeout(obj, 0); } /*========================================================================== ** Version of TryEnter that will block, but only up to a timeout period ** expressed in milliseconds. If timeout == Timeout.Infinite the method ** becomes equivalent to Enter. ** ** Exceptions: ArgumentNullException if object is null. ** ArgumentException if timeout < 0. =========================================================================*/ public static bool TryEnter(Object obj, int millisecondsTimeout) { return TryEnterTimeout(obj, millisecondsTimeout); } public static bool TryEnter(Object obj, TimeSpan timeout) { long tm = (long)timeout.TotalMilliseconds; if (tm < -1 || tm > (long) Int32.MaxValue) throw new ArgumentOutOfRangeException("timeout", Environment.GetResourceString("ArgumentOutOfRange_NeedNonNegOrNegative1")); return TryEnterTimeout(obj, (int)tm); } [MethodImplAttribute(MethodImplOptions.InternalCall)] private static extern bool TryEnterTimeout(Object obj, int timeout); /*======================================================================= ** Waits for notification from the object (via a Pulse/PulseAll). ** timeout indicates how long to wait before the method returns. ** This method acquires the monitor waithandle for the object ** If this thread holds the monitor lock for the object, it releases it. ** On exit from the method, it obtains the monitor lock back. ** If exitContext is true then the synchronization domain for the context ** (if in a synchronized context) is exited before the wait and reacquired ** ** Exceptions: ArgumentNullException if object is null. ========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] private static extern bool ObjWait(bool exitContext, int millisecondsTimeout,Object obj); public static bool Wait(Object obj, int millisecondsTimeout, bool exitContext) { if (obj == null) throw (new ArgumentNullException("obj")); return ObjWait(exitContext, millisecondsTimeout, obj); } public static bool Wait(Object obj, TimeSpan timeout, bool exitContext) { long tm = (long)timeout.TotalMilliseconds; if (tm < -1 || tm > (long) Int32.MaxValue) throw new ArgumentOutOfRangeException("timeout", Environment.GetResourceString("ArgumentOutOfRange_NeedNonNegOrNegative1")); return Wait(obj, (int)tm, exitContext); } public static bool Wait(Object obj, int millisecondsTimeout) { return Wait(obj,millisecondsTimeout,false); } public static bool Wait(Object obj, TimeSpan timeout) { long tm = (long)timeout.TotalMilliseconds; if (tm < -1 || tm > (long) Int32.MaxValue) throw new ArgumentOutOfRangeException("timeout", Environment.GetResourceString("ArgumentOutOfRange_NeedNonNegOrNegative1")); return Wait(obj,(int)tm,false); } public static bool Wait(Object obj) { return Wait(obj,Timeout.Infinite,false); } /*======================================================================== ** Sends a notification to a single waiting object. * Exceptions: SynchronizationLockException if this method is not called inside * a synchronized block of code. ========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] private static extern void ObjPulse(Object obj); public static void Pulse(Object obj) { if (obj==null) { throw new ArgumentNullException("obj"); } ObjPulse(obj); } /*======================================================================== ** Sends a notification to all waiting objects. ========================================================================*/ [MethodImplAttribute(MethodImplOptions.InternalCall)] private static extern void ObjPulseAll(Object obj); public static void PulseAll(Object obj) { if (obj==null) { throw new ArgumentNullException("obj"); } ObjPulseAll(obj); } } } // 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
- ExtensionQuery.cs
- ResourcePermissionBaseEntry.cs
- SynthesizerStateChangedEventArgs.cs
- SiteMapNodeCollection.cs
- LicenseProviderAttribute.cs
- SplashScreenNativeMethods.cs
- XmlEventCache.cs
- DataGridViewBand.cs
- UrlUtility.cs
- ConfigurationElementCollection.cs
- DoubleKeyFrameCollection.cs
- PathFigureCollection.cs
- HeaderElement.cs
- Visual3D.cs
- BamlResourceDeserializer.cs
- EventLogConfiguration.cs
- ChangeBlockUndoRecord.cs
- _HeaderInfoTable.cs
- DataContext.cs
- RangeValuePattern.cs
- TypeDescriptionProviderAttribute.cs
- HostingEnvironment.cs
- SmtpSpecifiedPickupDirectoryElement.cs
- SqlDataSourceFilteringEventArgs.cs
- XPathNodeInfoAtom.cs
- DelegateBodyWriter.cs
- XmlSchemaAll.cs
- AddInController.cs
- TimelineCollection.cs
- BrowserCapabilitiesFactory35.cs
- SubpageParagraph.cs
- ColorMap.cs
- ManagementScope.cs
- ShellProvider.cs
- SweepDirectionValidation.cs
- ReferencedAssemblyResolver.cs
- HttpCacheVaryByContentEncodings.cs
- ProjectionCamera.cs
- HttpCookiesSection.cs
- WebPartEditorCancelVerb.cs
- SafeProcessHandle.cs
- KeyGestureValueSerializer.cs
- SqlTriggerAttribute.cs
- AppSettingsExpressionBuilder.cs
- Ray3DHitTestResult.cs
- BypassElement.cs
- BrowserInteropHelper.cs
- DataTableReader.cs
- ConfigurationErrorsException.cs
- ResolveCriteriaApril2005.cs
- XdrBuilder.cs
- UnsafeNativeMethods.cs
- HasCopySemanticsAttribute.cs
- HttpCapabilitiesBase.cs
- KeyboardDevice.cs
- ProfileBuildProvider.cs
- DiscardableAttribute.cs
- ApplicationSettingsBase.cs
- Rfc2898DeriveBytes.cs
- ValueChangedEventManager.cs
- ProviderCollection.cs
- ReadOnlyPermissionSet.cs
- Slider.cs
- TraceLevelStore.cs
- DropAnimation.xaml.cs
- XmlSchemaObjectCollection.cs
- ComponentDispatcher.cs
- CredentialCache.cs
- BuildProvider.cs
- XmlName.cs
- TextBox.cs
- WindowsStatic.cs
- PseudoWebRequest.cs
- FontFamily.cs
- DbSetClause.cs
- BitmapEffectInput.cs
- Animatable.cs
- Exceptions.cs
- BamlTreeUpdater.cs
- DLinqTableProvider.cs
- BitmapPalette.cs
- Point3DConverter.cs
- cache.cs
- QilLoop.cs
- DeviceSpecificChoice.cs
- DataGrid.cs
- DbDataSourceEnumerator.cs
- TextViewBase.cs
- TextServicesHost.cs
- PropertyGeneratedEventArgs.cs
- ReverseInheritProperty.cs
- XmlTypeMapping.cs
- OdbcEnvironmentHandle.cs
- RightsManagementEncryptedStream.cs
- ConfigurationValidatorAttribute.cs
- ButtonColumn.cs
- UrlMappingsModule.cs
- EncodingNLS.cs
- Stack.cs
- SQLMoneyStorage.cs