Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / whidbey / netfxsp / ndp / fx / src / Sys / System / Runtime / InteropServices / HandleCollector.cs / 1 / HandleCollector.cs
// ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== namespace System.Runtime.InteropServices { using System; using System.Threading; public sealed class HandleCollector { private const int deltaPercent = 10; // this is used for increasing the threshold. private string name; private int initialThreshold; private int maximumThreshold; private int threshold; private int handleCount; private int[] gc_counts = new int [3]; private int gc_gen = 0; public HandleCollector( string name, int initialThreshold ) : this( name, initialThreshold, int.MaxValue) { } public HandleCollector( string name, int initialThreshold, int maximumThreshold ) { if( initialThreshold < 0) { throw new ArgumentOutOfRangeException("initialThreshold", SR.GetString(SR.ArgumentOutOfRange_NeedNonNegNumRequired)); } if( maximumThreshold < 0) { throw new ArgumentOutOfRangeException("maximumThreshold", SR.GetString(SR.ArgumentOutOfRange_NeedNonNegNumRequired)); } if( initialThreshold > maximumThreshold) { throw new ArgumentException(SR.GetString(SR.Argument_InvalidThreshold)); } if ( name != null) { this.name = name; } else { this.name = String.Empty; } this.initialThreshold = initialThreshold; this.maximumThreshold = maximumThreshold ; this.threshold = initialThreshold; this.handleCount = 0; } public int Count { get {return handleCount;} } public int InitialThreshold { get { return initialThreshold;} } public int MaximumThreshold { get { return maximumThreshold;} } public string Name { get {return name;} } [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Reliability", "CA2001:AvoidCallingProblematicMethods")] // Keep call to GC.Collect() public void Add () { int gen_collect = -1; Interlocked.Increment( ref handleCount); if( handleCount < 0) { throw new InvalidOperationException(SR.GetString(SR.InvalidOperation_HCCountOverflow)); } if (handleCount > threshold) { lock (this) { threshold = handleCount + (handleCount/deltaPercent); gen_collect = gc_gen; if (gc_gen < 2) { gc_gen++; } } } if ((gen_collect >= 0) && ((gen_collect == 0) || (gc_counts[gen_collect] == GC.CollectionCount (gen_collect)))) { GC.Collect (gen_collect); Thread.Sleep (10*gen_collect); } //don't bother with gen0. for (int i = 1; i < 3; i++) { gc_counts [i] = GC.CollectionCount (i); } } public void Remove () { Interlocked.Decrement( ref handleCount); if (handleCount < 0) { throw new InvalidOperationException(SR.GetString(SR.InvalidOperation_HCCountOverflow)); } int newThreshold = handleCount + handleCount/deltaPercent; if (newThreshold < (threshold - threshold/deltaPercent)) { lock( this) { if (newThreshold > initialThreshold) { threshold = newThreshold; } else { threshold = initialThreshold; } gc_gen = 0; } } for (int i = 1; i < 3; i++) { gc_counts [i] = GC.CollectionCount (i); } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // ==++== // // Copyright (c) Microsoft Corporation. All rights reserved. // // ==--== namespace System.Runtime.InteropServices { using System; using System.Threading; public sealed class HandleCollector { private const int deltaPercent = 10; // this is used for increasing the threshold. private string name; private int initialThreshold; private int maximumThreshold; private int threshold; private int handleCount; private int[] gc_counts = new int [3]; private int gc_gen = 0; public HandleCollector( string name, int initialThreshold ) : this( name, initialThreshold, int.MaxValue) { } public HandleCollector( string name, int initialThreshold, int maximumThreshold ) { if( initialThreshold < 0) { throw new ArgumentOutOfRangeException("initialThreshold", SR.GetString(SR.ArgumentOutOfRange_NeedNonNegNumRequired)); } if( maximumThreshold < 0) { throw new ArgumentOutOfRangeException("maximumThreshold", SR.GetString(SR.ArgumentOutOfRange_NeedNonNegNumRequired)); } if( initialThreshold > maximumThreshold) { throw new ArgumentException(SR.GetString(SR.Argument_InvalidThreshold)); } if ( name != null) { this.name = name; } else { this.name = String.Empty; } this.initialThreshold = initialThreshold; this.maximumThreshold = maximumThreshold ; this.threshold = initialThreshold; this.handleCount = 0; } public int Count { get {return handleCount;} } public int InitialThreshold { get { return initialThreshold;} } public int MaximumThreshold { get { return maximumThreshold;} } public string Name { get {return name;} } [System.Diagnostics.CodeAnalysis.SuppressMessage("Microsoft.Reliability", "CA2001:AvoidCallingProblematicMethods")] // Keep call to GC.Collect() public void Add () { int gen_collect = -1; Interlocked.Increment( ref handleCount); if( handleCount < 0) { throw new InvalidOperationException(SR.GetString(SR.InvalidOperation_HCCountOverflow)); } if (handleCount > threshold) { lock (this) { threshold = handleCount + (handleCount/deltaPercent); gen_collect = gc_gen; if (gc_gen < 2) { gc_gen++; } } } if ((gen_collect >= 0) && ((gen_collect == 0) || (gc_counts[gen_collect] == GC.CollectionCount (gen_collect)))) { GC.Collect (gen_collect); Thread.Sleep (10*gen_collect); } //don't bother with gen0. for (int i = 1; i < 3; i++) { gc_counts [i] = GC.CollectionCount (i); } } public void Remove () { Interlocked.Decrement( ref handleCount); if (handleCount < 0) { throw new InvalidOperationException(SR.GetString(SR.InvalidOperation_HCCountOverflow)); } int newThreshold = handleCount + handleCount/deltaPercent; if (newThreshold < (threshold - threshold/deltaPercent)) { lock( this) { if (newThreshold > initialThreshold) { threshold = newThreshold; } else { threshold = initialThreshold; } gc_gen = 0; } } for (int i = 1; i < 3; i++) { gc_counts [i] = GC.CollectionCount (i); } } } } // 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
- XslCompiledTransform.cs
- SqlDataAdapter.cs
- DebugView.cs
- HMACSHA384.cs
- SignatureGenerator.cs
- MessageRpc.cs
- OrderByQueryOptionExpression.cs
- WpfKnownMemberInvoker.cs
- WebControlAdapter.cs
- StrongNameUtility.cs
- HttpHandlersInstallComponent.cs
- DataRowCollection.cs
- GridViewRowCollection.cs
- StateMachineWorkflowInstance.cs
- Events.cs
- WindowPattern.cs
- ExtendedPropertyCollection.cs
- ZipIOZip64EndOfCentralDirectoryBlock.cs
- PropertyChangingEventArgs.cs
- SchemaImporterExtension.cs
- Timeline.cs
- InstalledVoice.cs
- XPathEmptyIterator.cs
- SiteOfOriginContainer.cs
- EntityViewGenerationAttribute.cs
- BuilderPropertyEntry.cs
- OverflowException.cs
- SystemIPv6InterfaceProperties.cs
- SharedPerformanceCounter.cs
- GridViewPageEventArgs.cs
- TextElementCollectionHelper.cs
- ObjectReaderCompiler.cs
- ResourceReferenceExpression.cs
- Label.cs
- PrintingPermissionAttribute.cs
- WindowPattern.cs
- QueuedDeliveryRequirementsMode.cs
- XamlDesignerSerializationManager.cs
- Subset.cs
- EditorBrowsableAttribute.cs
- MachineKey.cs
- PrimarySelectionAdorner.cs
- DragCompletedEventArgs.cs
- SharedStream.cs
- InternalCache.cs
- XD.cs
- RegisteredDisposeScript.cs
- FixedPageAutomationPeer.cs
- EncoderReplacementFallback.cs
- AssociationProvider.cs
- CharacterBuffer.cs
- ReflectionHelper.cs
- GroupPartitionExpr.cs
- DefaultProxySection.cs
- WebPart.cs
- UmAlQuraCalendar.cs
- ConfigurationSchemaErrors.cs
- WorkflowMarkupSerializationException.cs
- MultiSelectRootGridEntry.cs
- SqlGatherProducedAliases.cs
- InstanceDataCollectionCollection.cs
- SafeFileMappingHandle.cs
- CSharpCodeProvider.cs
- SchemaTypeEmitter.cs
- WindowsFormsSynchronizationContext.cs
- SessionEndingCancelEventArgs.cs
- ResolveCompletedEventArgs.cs
- DebuggerAttributes.cs
- FontWeight.cs
- EntityStoreSchemaFilterEntry.cs
- DrawingBrush.cs
- ChangeNode.cs
- ProfileService.cs
- GB18030Encoding.cs
- PowerModeChangedEventArgs.cs
- FormViewPageEventArgs.cs
- ConstNode.cs
- MD5.cs
- WindowsGraphics2.cs
- xml.cs
- CheckedPointers.cs
- ParameterBuilder.cs
- TextClipboardData.cs
- XhtmlBasicPhoneCallAdapter.cs
- TextCompositionManager.cs
- DebugController.cs
- ParsedAttributeCollection.cs
- ClientConfigPaths.cs
- LogFlushAsyncResult.cs
- SvcMapFileSerializer.cs
- SoapAttributeOverrides.cs
- ToolStripOverflow.cs
- SqlInternalConnectionTds.cs
- TrackingStringDictionary.cs
- DesignerTextWriter.cs
- WindowsListViewItemStartMenu.cs
- SqlConnectionPoolGroupProviderInfo.cs
- ActivityInstance.cs
- TypeAccessException.cs
- EnumDataContract.cs