Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / 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
- SmtpReplyReaderFactory.cs
- TypeConverterAttribute.cs
- FormViewModeEventArgs.cs
- DataServiceRequest.cs
- DataGridColumn.cs
- DesignBindingPicker.cs
- WindowsProgressbar.cs
- SiteOfOriginPart.cs
- DockingAttribute.cs
- UpdatableGenericsFeature.cs
- NavigationExpr.cs
- TagPrefixAttribute.cs
- OneOfElement.cs
- UdpTransportSettings.cs
- Hash.cs
- XmlParser.cs
- HwndSubclass.cs
- TextCompositionEventArgs.cs
- PropVariant.cs
- Section.cs
- SerializationObjectManager.cs
- OdbcConnectionFactory.cs
- FacetValues.cs
- WrappedOptions.cs
- ListInitExpression.cs
- DataGridViewRowsAddedEventArgs.cs
- TypeName.cs
- TextBlockAutomationPeer.cs
- XmlnsCompatibleWithAttribute.cs
- RayHitTestParameters.cs
- QilReplaceVisitor.cs
- NoneExcludedImageIndexConverter.cs
- ClusterRegistryConfigurationProvider.cs
- TypedDataSetSchemaImporterExtensionFx35.cs
- DependencyPropertyHelper.cs
- FontCacheUtil.cs
- BaseCollection.cs
- HtmlTextArea.cs
- StaticExtension.cs
- ExternalException.cs
- FrameworkTextComposition.cs
- IERequestCache.cs
- WebPartVerb.cs
- RequestStatusBarUpdateEventArgs.cs
- SourceInterpreter.cs
- LabelLiteral.cs
- WeakReadOnlyCollection.cs
- XPathArrayIterator.cs
- RuleSetDialog.cs
- Models.cs
- QueryContinueDragEventArgs.cs
- CmsUtils.cs
- SByte.cs
- SqlBulkCopy.cs
- AudioFileOut.cs
- CharacterBuffer.cs
- PowerModeChangedEventArgs.cs
- XmlSchemaRedefine.cs
- ZoneLinkButton.cs
- Matrix3DValueSerializer.cs
- ToolStripDropDownClosedEventArgs.cs
- MessageHeaders.cs
- WebHttpBehavior.cs
- EncryptedData.cs
- SoundPlayer.cs
- Variable.cs
- TypeDependencyAttribute.cs
- DrawToolTipEventArgs.cs
- InputLanguage.cs
- SecurityKeyIdentifierClause.cs
- TreeViewItem.cs
- DecimalConstantAttribute.cs
- ErrorRuntimeConfig.cs
- TableLayout.cs
- IntPtr.cs
- HtmlShim.cs
- Aes.cs
- MasterPage.cs
- ScalarOps.cs
- FrameworkRichTextComposition.cs
- DataGridAutoFormat.cs
- TdsParserSessionPool.cs
- SharedPersonalizationStateInfo.cs
- TypographyProperties.cs
- SingleObjectCollection.cs
- XamlBrushSerializer.cs
- DbParameterHelper.cs
- TypeSource.cs
- SymmetricSecurityProtocolFactory.cs
- BypassElementCollection.cs
- MetadataWorkspace.cs
- SqlGatherProducedAliases.cs
- BindableTemplateBuilder.cs
- XmlSignatureManifest.cs
- DebugTraceHelper.cs
- RenderDataDrawingContext.cs
- ToolStripDropDownItemDesigner.cs
- StringFreezingAttribute.cs
- ActivationArguments.cs
- String.cs