Code:
/ FXUpdate3074 / FXUpdate3074 / 1.1 / DEVDIV / depot / DevDiv / releases / whidbey / QFE / ndp / fx / src / xsp / System / Web / BufferAllocator.cs / 1 / BufferAllocator.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- /* * Buffer Allocators with recycling * * Copyright (c) 1999 Microsoft Corporation */ namespace System.Web { using System.Collections; using System.IO; using System.Globalization; using System.Web.Util; ////////////////////////////////////////////////////////////////////////////// // Generic buffer recycling /* * Base class for allocator doing buffer recycling */ internal abstract class BufferAllocator { private int _maxFree; private int _numFree; private Stack _buffers; private static int s_ProcsFudgeFactor; static BufferAllocator() { s_ProcsFudgeFactor = SystemInfo.GetNumProcessCPUs(); if (s_ProcsFudgeFactor < 1) s_ProcsFudgeFactor = 1; if (s_ProcsFudgeFactor > 4) s_ProcsFudgeFactor = 4; } internal BufferAllocator(int maxFree) { _buffers = new Stack(); _numFree = 0; _maxFree = maxFree * s_ProcsFudgeFactor; } internal /*public*/ Object GetBuffer() { Object buffer = null; if (_numFree > 0) { lock(this) { if (_numFree > 0) { buffer = _buffers.Pop(); _numFree--; } } } if (buffer == null) buffer = AllocBuffer(); return buffer; } internal void ReuseBuffer(Object buffer) { if (_numFree < _maxFree) { lock(this) { if (_numFree < _maxFree) { _buffers.Push(buffer); _numFree++; } } } } /* * To be implemented by a derived class */ abstract protected Object AllocBuffer(); } /* * Concrete allocator class for ubyte[] buffer recycling */ internal class UbyteBufferAllocator : BufferAllocator { private int _bufferSize; internal UbyteBufferAllocator(int bufferSize, int maxFree) : base(maxFree) { _bufferSize = bufferSize; } protected override Object AllocBuffer() { return new byte[_bufferSize]; } } /* * Concrete allocator class for char[] buffer recycling */ internal class CharBufferAllocator : BufferAllocator { private int _bufferSize; internal CharBufferAllocator(int bufferSize, int maxFree) : base(maxFree) { _bufferSize = bufferSize; } protected override Object AllocBuffer() { return new char[_bufferSize]; } } /* * Concrete allocator class for int[] buffer recycling */ internal class IntegerArrayAllocator : BufferAllocator { private int _arraySize; internal IntegerArrayAllocator(int arraySize, int maxFree) : base(maxFree) { _arraySize = arraySize; } protected override Object AllocBuffer() { return new int[_arraySize]; } } /* * Concrete allocator class for IntPtr[] buffer recycling */ internal class IntPtrArrayAllocator : BufferAllocator { private int _arraySize; internal IntPtrArrayAllocator(int arraySize, int maxFree) : base(maxFree) { _arraySize = arraySize; } protected override Object AllocBuffer() { return new IntPtr[_arraySize]; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved. //------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- /* * Buffer Allocators with recycling * * Copyright (c) 1999 Microsoft Corporation */ namespace System.Web { using System.Collections; using System.IO; using System.Globalization; using System.Web.Util; ////////////////////////////////////////////////////////////////////////////// // Generic buffer recycling /* * Base class for allocator doing buffer recycling */ internal abstract class BufferAllocator { private int _maxFree; private int _numFree; private Stack _buffers; private static int s_ProcsFudgeFactor; static BufferAllocator() { s_ProcsFudgeFactor = SystemInfo.GetNumProcessCPUs(); if (s_ProcsFudgeFactor < 1) s_ProcsFudgeFactor = 1; if (s_ProcsFudgeFactor > 4) s_ProcsFudgeFactor = 4; } internal BufferAllocator(int maxFree) { _buffers = new Stack(); _numFree = 0; _maxFree = maxFree * s_ProcsFudgeFactor; } internal /*public*/ Object GetBuffer() { Object buffer = null; if (_numFree > 0) { lock(this) { if (_numFree > 0) { buffer = _buffers.Pop(); _numFree--; } } } if (buffer == null) buffer = AllocBuffer(); return buffer; } internal void ReuseBuffer(Object buffer) { if (_numFree < _maxFree) { lock(this) { if (_numFree < _maxFree) { _buffers.Push(buffer); _numFree++; } } } } /* * To be implemented by a derived class */ abstract protected Object AllocBuffer(); } /* * Concrete allocator class for ubyte[] buffer recycling */ internal class UbyteBufferAllocator : BufferAllocator { private int _bufferSize; internal UbyteBufferAllocator(int bufferSize, int maxFree) : base(maxFree) { _bufferSize = bufferSize; } protected override Object AllocBuffer() { return new byte[_bufferSize]; } } /* * Concrete allocator class for char[] buffer recycling */ internal class CharBufferAllocator : BufferAllocator { private int _bufferSize; internal CharBufferAllocator(int bufferSize, int maxFree) : base(maxFree) { _bufferSize = bufferSize; } protected override Object AllocBuffer() { return new char[_bufferSize]; } } /* * Concrete allocator class for int[] buffer recycling */ internal class IntegerArrayAllocator : BufferAllocator { private int _arraySize; internal IntegerArrayAllocator(int arraySize, int maxFree) : base(maxFree) { _arraySize = arraySize; } protected override Object AllocBuffer() { return new int[_arraySize]; } } /* * Concrete allocator class for IntPtr[] buffer recycling */ internal class IntPtrArrayAllocator : BufferAllocator { private int _arraySize; internal IntPtrArrayAllocator(int arraySize, int maxFree) : base(maxFree) { _arraySize = arraySize; } protected override Object AllocBuffer() { return new IntPtr[_arraySize]; } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- DataTableReader.cs
- XamlTemplateSerializer.cs
- XmlNodeReader.cs
- FileDialogCustomPlace.cs
- Predicate.cs
- SettingsPropertyIsReadOnlyException.cs
- DriveInfo.cs
- AbsoluteQuery.cs
- UnmanagedMemoryStreamWrapper.cs
- OpenTypeLayout.cs
- GridViewCellAutomationPeer.cs
- Int64Converter.cs
- UpdateEventArgs.cs
- UnaryNode.cs
- CompareInfo.cs
- CredentialCache.cs
- DataGridViewHeaderCell.cs
- SiteMapHierarchicalDataSourceView.cs
- FixedTextSelectionProcessor.cs
- MailMessage.cs
- RoleBoolean.cs
- _AutoWebProxyScriptHelper.cs
- MasterPageParser.cs
- RuntimeCompatibilityAttribute.cs
- PropertyChangedEventArgs.cs
- InputProcessorProfiles.cs
- EntitySetBaseCollection.cs
- TextServicesContext.cs
- SystemMulticastIPAddressInformation.cs
- ITextView.cs
- PointAnimation.cs
- FamilyCollection.cs
- CategoryAttribute.cs
- ElapsedEventArgs.cs
- ToolStripDropTargetManager.cs
- SynchronizationContext.cs
- SecurityHeader.cs
- SystemInfo.cs
- ValidationEventArgs.cs
- CLRBindingWorker.cs
- UserPrincipalNameElement.cs
- TextElementEnumerator.cs
- EditorServiceContext.cs
- ElementNotAvailableException.cs
- Timer.cs
- AccessedThroughPropertyAttribute.cs
- CrossAppDomainChannel.cs
- WindowAutomationPeer.cs
- SqlUserDefinedAggregateAttribute.cs
- NotifyIcon.cs
- NativeCppClassAttribute.cs
- WindowsEditBox.cs
- XmlNullResolver.cs
- GroupItemAutomationPeer.cs
- RtfToXamlReader.cs
- FactoryGenerator.cs
- EntityCommandCompilationException.cs
- TextServicesDisplayAttributePropertyRanges.cs
- PriorityRange.cs
- InvokeMethodActivity.cs
- BindingWorker.cs
- DataControlCommands.cs
- ScrollProperties.cs
- StringOutput.cs
- _KerberosClient.cs
- AppDomainShutdownMonitor.cs
- ViewBox.cs
- LateBoundBitmapDecoder.cs
- XmlSchemaInferenceException.cs
- XmlNodeComparer.cs
- StrongTypingException.cs
- ComplexObject.cs
- FacetChecker.cs
- WebPartRestoreVerb.cs
- Int64Converter.cs
- XmlAttribute.cs
- FailedToStartupUIException.cs
- LeaseManager.cs
- TextRenderer.cs
- DodSequenceMerge.cs
- SafeRightsManagementEnvironmentHandle.cs
- SqlRowUpdatedEvent.cs
- XmlILOptimizerVisitor.cs
- OleDbParameterCollection.cs
- RtfToXamlReader.cs
- Authorization.cs
- PaintEvent.cs
- RoleGroupCollection.cs
- Helpers.cs
- MailWriter.cs
- x509utils.cs
- DrawingState.cs
- FixedSOMContainer.cs
- ControlCollection.cs
- TypeLoadException.cs
- WindowsRichEditRange.cs
- SerialPinChanges.cs
- ResourceBinder.cs
- GatewayDefinition.cs
- OracleCommandSet.cs