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
- TypeConstant.cs
- GACMembershipCondition.cs
- PointAnimationBase.cs
- StreamInfo.cs
- AppearanceEditorPart.cs
- XmlSubtreeReader.cs
- SchemaHelper.cs
- AvtEvent.cs
- VBCodeProvider.cs
- DescendantOverDescendantQuery.cs
- PngBitmapDecoder.cs
- DataGridViewColumnDesignTimeVisibleAttribute.cs
- SecurityTokenSerializer.cs
- DiscoveryInnerClientAdhocCD1.cs
- _TimerThread.cs
- SrgsElement.cs
- MenuItemStyleCollection.cs
- ValidationRuleCollection.cs
- HttpListenerRequest.cs
- EventDescriptor.cs
- StrongNameKeyPair.cs
- CodeAssignStatement.cs
- ObjectPersistData.cs
- x509store.cs
- ArrayTypeMismatchException.cs
- XmlValueConverter.cs
- TableRowCollection.cs
- webeventbuffer.cs
- DSACryptoServiceProvider.cs
- LineMetrics.cs
- ArraySortHelper.cs
- Window.cs
- DependencyStoreSurrogate.cs
- FastEncoder.cs
- Animatable.cs
- DispatchWrapper.cs
- ServiceProviders.cs
- _StreamFramer.cs
- AnimationException.cs
- XslException.cs
- NumericUpDown.cs
- _NetworkingPerfCounters.cs
- ProfileModule.cs
- DataGridViewButtonCell.cs
- AesManaged.cs
- Relationship.cs
- AmbientProperties.cs
- AssociationEndMember.cs
- KnownIds.cs
- MergeFilterQuery.cs
- ToolStripDropDownButton.cs
- RoamingStoreFile.cs
- NotifyInputEventArgs.cs
- UpdateCommand.cs
- EllipseGeometry.cs
- CookieProtection.cs
- WsdlInspector.cs
- DelegateArgumentReference.cs
- ColorTransform.cs
- Zone.cs
- KeyTime.cs
- UdpChannelFactory.cs
- Int32Rect.cs
- RowType.cs
- AllMembershipCondition.cs
- BinaryKeyIdentifierClause.cs
- CheckBox.cs
- CapabilitiesPattern.cs
- XLinq.cs
- ThreadExceptionEvent.cs
- XmlAtomicValue.cs
- FileDialog.cs
- TypeGeneratedEventArgs.cs
- SoapSchemaImporter.cs
- LinqDataSourceSelectEventArgs.cs
- PrintDialog.cs
- FileUtil.cs
- BrowserDefinitionCollection.cs
- CommandID.cs
- TranslateTransform3D.cs
- ReadOnlyCollectionBase.cs
- ClientApiGenerator.cs
- Pair.cs
- ListViewItemSelectionChangedEvent.cs
- LiteralControl.cs
- DataControlFieldCollection.cs
- DoubleLinkListEnumerator.cs
- SqlDataReaderSmi.cs
- ZipPackage.cs
- InstancePersistenceCommand.cs
- HttpClientCertificate.cs
- SortQuery.cs
- UnauthorizedWebPart.cs
- ConnectionManagementElement.cs
- XmlExpressionDumper.cs
- PathParser.cs
- PropertyItemInternal.cs
- RayHitTestParameters.cs
- SqlCommandBuilder.cs
- SafeArchiveContext.cs