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
- WebHttpDispatchOperationSelectorData.cs
- OutputCacheProviderCollection.cs
- ParameterCollection.cs
- Formatter.cs
- TypedReference.cs
- FrameSecurityDescriptor.cs
- ComponentResourceKey.cs
- CompositionDesigner.cs
- HtmlTextBoxAdapter.cs
- ReadOnlyHierarchicalDataSourceView.cs
- XPathMultyIterator.cs
- AlgoModule.cs
- DataRelation.cs
- FragmentQueryProcessor.cs
- CompoundFileDeflateTransform.cs
- keycontainerpermission.cs
- PageThemeParser.cs
- WpfMemberInvoker.cs
- InkCanvas.cs
- HttpClientChannel.cs
- CharacterShapingProperties.cs
- IisTraceWebEventProvider.cs
- ChtmlTextWriter.cs
- CollectionDataContract.cs
- HttpCacheVary.cs
- MessagingActivityHelper.cs
- Int32Storage.cs
- QueryOpeningEnumerator.cs
- Base64Stream.cs
- SingleSelectRootGridEntry.cs
- sortedlist.cs
- GroupBoxAutomationPeer.cs
- XPathDocument.cs
- Image.cs
- TableLayout.cs
- CustomAttributeFormatException.cs
- SmiMetaDataProperty.cs
- DataServiceExpressionVisitor.cs
- ChannelManagerHelpers.cs
- PartialCachingAttribute.cs
- FormsAuthenticationUser.cs
- Point.cs
- PerformanceCounterManager.cs
- DetailsViewCommandEventArgs.cs
- TypeLibConverter.cs
- TypeConvertions.cs
- EdmScalarPropertyAttribute.cs
- RecommendedAsConfigurableAttribute.cs
- odbcmetadatafactory.cs
- DataGridItemCollection.cs
- ConnectionsZoneDesigner.cs
- RegexRunnerFactory.cs
- AttributeUsageAttribute.cs
- Msec.cs
- TabPage.cs
- BypassElementCollection.cs
- GetPageCompletedEventArgs.cs
- TransformerInfo.cs
- StandardOleMarshalObject.cs
- DataGridCellAutomationPeer.cs
- _NativeSSPI.cs
- Animatable.cs
- WebPartHeaderCloseVerb.cs
- Mappings.cs
- RuleEngine.cs
- DefaultSerializationProviderAttribute.cs
- CommonObjectSecurity.cs
- ToolStripArrowRenderEventArgs.cs
- OletxDependentTransaction.cs
- DesignerSerializerAttribute.cs
- OutputCacheSettingsSection.cs
- WizardForm.cs
- ColorIndependentAnimationStorage.cs
- DesignerWithHeader.cs
- ReadOnlyDataSourceView.cs
- SafeEventLogWriteHandle.cs
- PartialList.cs
- SortExpressionBuilder.cs
- BaseTemplateParser.cs
- DataSourceHelper.cs
- DesignerAttribute.cs
- TextOptions.cs
- CroppedBitmap.cs
- EditingContext.cs
- OdbcUtils.cs
- FullTextLine.cs
- IImplicitResourceProvider.cs
- WebBrowserNavigatedEventHandler.cs
- GroupAggregateExpr.cs
- ExternalFile.cs
- LockedActivityGlyph.cs
- ElementHostAutomationPeer.cs
- SortedList.cs
- PolicyImporterElement.cs
- Pen.cs
- FillErrorEventArgs.cs
- VScrollProperties.cs
- XPathQilFactory.cs
- Constants.cs
- LinkButton.cs