Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / whidbey / NetFxQFE / 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
- QilScopedVisitor.cs
- Bidi.cs
- ScalarType.cs
- BuildResultCache.cs
- CookieProtection.cs
- DataGridCommandEventArgs.cs
- LocalBuilder.cs
- Transform.cs
- DataListItem.cs
- XmlNullResolver.cs
- XmlUtf8RawTextWriter.cs
- XPathBuilder.cs
- ConfigXmlElement.cs
- BaseParagraph.cs
- SafeNativeMemoryHandle.cs
- ReadOnlyHierarchicalDataSource.cs
- Compilation.cs
- ReadContentAsBinaryHelper.cs
- SignatureDescription.cs
- ToolboxComponentsCreatingEventArgs.cs
- CqlErrorHelper.cs
- sqlser.cs
- CalculatedColumn.cs
- returneventsaver.cs
- EndPoint.cs
- EngineSite.cs
- DynamicDiscoSearcher.cs
- _BufferOffsetSize.cs
- SaveFileDialog.cs
- Documentation.cs
- MenuItemStyleCollection.cs
- WebRequestModuleElement.cs
- ProviderIncompatibleException.cs
- ZoomComboBox.cs
- Int16Converter.cs
- FlowDocumentFormatter.cs
- ItemCollection.cs
- FormViewInsertedEventArgs.cs
- _Events.cs
- Int16.cs
- DbgUtil.cs
- Wizard.cs
- ControllableStoryboardAction.cs
- SchemaElementDecl.cs
- Int32AnimationUsingKeyFrames.cs
- StandardOleMarshalObject.cs
- XmlNodeComparer.cs
- SqlConnection.cs
- XmlUTF8TextReader.cs
- InternalCache.cs
- arabicshape.cs
- Vertex.cs
- RenderingBiasValidation.cs
- FSWPathEditor.cs
- FileLevelControlBuilderAttribute.cs
- MeasurementDCInfo.cs
- ProjectionPathBuilder.cs
- UseAttributeSetsAction.cs
- ClockGroup.cs
- DateTimeConverter2.cs
- NativeMethods.cs
- objectquery_tresulttype.cs
- TranslateTransform.cs
- Cursor.cs
- CalendarBlackoutDatesCollection.cs
- StreamingContext.cs
- EntityStoreSchemaFilterEntry.cs
- SafeFileHandle.cs
- Symbol.cs
- PermissionToken.cs
- XmlSerializerVersionAttribute.cs
- UserPreferenceChangedEventArgs.cs
- SiteMapDataSourceView.cs
- WizardSideBarListControlItemEventArgs.cs
- KnownAssembliesSet.cs
- StoragePropertyMapping.cs
- CriticalExceptions.cs
- SafeFileHandle.cs
- XmlC14NWriter.cs
- Int32.cs
- OdbcCommand.cs
- WS2007FederationHttpBinding.cs
- SmiMetaDataProperty.cs
- SecurityContext.cs
- GridViewUpdatedEventArgs.cs
- HtmlSelect.cs
- Flowchart.cs
- UnsafeNativeMethods.cs
- MouseEventArgs.cs
- DynamicValueConverter.cs
- ECDiffieHellmanCngPublicKey.cs
- Propagator.cs
- DelegateSerializationHolder.cs
- SmiEventSink_Default.cs
- InvariantComparer.cs
- RoutedEventArgs.cs
- SafeProcessHandle.cs
- OperationInfoBase.cs
- CustomLineCap.cs
- TreeNodeCollection.cs