implab/ImplabNet Commit - r117:8beee0d11de6

pool refactoring

cin -

r117:8beee0d11de6 v2

parent child

Context file:

r117:8beee0d11de6

Collapse all files

Implab/DisposablePool.cs created 644 +90 0

@@ -0,0 +1,90
	1	using System;
	2	using Implab.Parallels;
	3	using System.Threading;
	4	using System.Diagnostics;
	5	using System.Diagnostics.CodeAnalysis;
	6
	7	namespace Implab {
	8	public abstract class DisposablePool<T> : IDisposable {
	9	readonly int m_size;
	10	readonly MTQueue<T> m_queue = new MTQueue<T>();
	11
	12	[SuppressMessage("Microsoft.Design", "CA1000:DoNotDeclareStaticMembersOnGenericTypes")]
	13	static readonly bool _isValueType = typeof(T).IsValueType;
	14
	15	bool m_disposed;
	16
	17	int m_count;
	18
	19	protected DisposablePool(int size) {
	20	m_size = size;
	21	}
	22
	23	protected DisposablePool() : this(Environment.ProcessorCount+1) {
	24	}
	25
	26	public T Allocate() {
	27	if (m_disposed)
	28	throw new ObjectDisposedException(ToString());
	29
	30	T instance;
	31	if (m_queue.TryDequeue(out instance)) {
	32	Interlocked.Decrement(ref m_count);
	33	} else {
	34	instance = CreateInstance();
	35	Debug.Assert(!Object.Equals(instance, default(T)) \|\| _isValueType);
	36	}
	37	return instance;
	38	}
	39
	40	protected abstract T CreateInstance();
	41
	42	protected virtual void CleanupInstance(T instance) {
	43	}
	44
	45	public void Release(T instance) {
	46	if ( Object.Equals(instance,default(T)) && !_isValueType)
	47	return;
	48
	49	Thread.MemoryBarrier();
	50	if (m_count < m_size && !m_disposed) {
	51	Interlocked.Increment(ref m_count);
	52
	53	CleanupInstance(instance);
	54
	55	m_queue.Enqueue(instance);
	56
	57	// пока элемент возвращался в кеш, была начата операция освобождения всего кеша
	58	// и возможно уже законцена, в таком случае следует извлечь элемент обратно и
	59	// освободить его. Если операция освобождения кеша еще не заврешилась, то будет
	60	// изъят и освобожден произвольный элемен, что не повлияет на ход всего процесса.
	61	if (m_disposed && m_queue.TryDequeue(out instance) && instance is IDisposable)
	62	((IDisposable)instance).Dispose() ;
	63
	64	} else {
	65	if (instance is IDisposable)
	66	((IDisposable)instance).Dispose();
	67	}
	68	}
	69
	70	protected virtual void Dispose(bool disposing) {
	71	if (disposing) {
	72	m_disposed = true;
	73	T instance;
	74	while (m_queue.TryDequeue(out instance))
	75	if (instance is IDisposable)
	76	((IDisposable)instance).Dispose();
	77	}
	78	}
	79
	80	#region IDisposable implementation
	81
	82	public void Dispose() {
	83	Dispose(true);
	84	GC.SuppressFinalize(this);
	85	}
	86
	87	#endregion
	88	}
	89	}
	90

Implab/Implab.csproj +2 -2

             <?xml version="1.0" encoding="utf-8"?>
             <Project DefaultTargets="Build" ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
               <PropertyGroup>
                 <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
                 <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
                 <ProjectGuid>{F550F1F8-8746-4AD0-9614-855F4C4B7F05}</ProjectGuid>
                 <OutputType>Library</OutputType>
                 <RootNamespace>Implab</RootNamespace>
                 <AssemblyName>Implab</AssemblyName>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug</OutputPath>
                 <DefineConstants>TRACE;DEBUG;</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
                 <RunCodeAnalysis>true</RunCodeAnalysis>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release|AnyCPU' ">
                 <DebugType>full</DebugType>
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release</OutputPath>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug 4.5|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug</OutputPath>
                 <DefineConstants>TRACE;DEBUG;NET_4_5</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <RunCodeAnalysis>true</RunCodeAnalysis>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Release 4.5|AnyCPU' ">
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release</OutputPath>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
                 <DefineConstants>NET_4_5</DefineConstants>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'DebugMono|AnyCPU' ">
                 <DebugSymbols>true</DebugSymbols>
                 <DebugType>full</DebugType>
                 <Optimize>false</Optimize>
                 <OutputPath>bin\Debug</OutputPath>
                 <DefineConstants>TRACE;DEBUG;NET_4_5;MONO</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <RunCodeAnalysis>true</RunCodeAnalysis>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'ReleaseMono|AnyCPU' ">
                 <Optimize>true</Optimize>
                 <OutputPath>bin\Release</OutputPath>
                 <DefineConstants>NET_4_5;MONO;</DefineConstants>
                 <ErrorReport>prompt</ErrorReport>
                 <WarningLevel>4</WarningLevel>
                 <ConsolePause>false</ConsolePause>
               </PropertyGroup>
               <ItemGroup>
                 <Reference Include="System" />
                 <Reference Include="System.Xml" />
               </ItemGroup>
               <ItemGroup>
                 <Compile Include="Component.cs" />
                 <Compile Include="CustomEqualityComparer.cs" />
                 <Compile Include="Diagnostics\ConsoleTraceListener.cs" />
                 <Compile Include="Diagnostics\EventText.cs" />
                 <Compile Include="Diagnostics\IEventTextFormatter.cs" />
                 <Compile Include="Diagnostics\LogChannel.cs" />
                 <Compile Include="Diagnostics\LogicalOperation.cs" />
                 <Compile Include="Diagnostics\TextFileListener.cs" />
                 <Compile Include="Diagnostics\TextListenerBase.cs" />
                 <Compile Include="Diagnostics\TraceLog.cs" />
                 <Compile Include="Diagnostics\TraceEvent.cs" />
                 <Compile Include="Diagnostics\TraceEventType.cs" />
                 <Compile Include="Disposable.cs" />
                 <Compile Include="ICancellable.cs" />
                 <Compile Include="IProgressHandler.cs" />
                 <Compile Include="IProgressNotifier.cs" />
                 <Compile Include="IPromiseT.cs" />
                 <Compile Include="IPromise.cs" />
                 <Compile Include="IServiceLocator.cs" />
                 <Compile Include="ITaskController.cs" />
                 <Compile Include="JSON\JSONElementContext.cs" />
                 <Compile Include="JSON\JSONElementType.cs" />
                 <Compile Include="JSON\JSONGrammar.cs" />
                 <Compile Include="JSON\JSONParser.cs" />
                 <Compile Include="JSON\JSONScanner.cs" />
                 <Compile Include="JSON\JsonTokenType.cs" />
                 <Compile Include="JSON\JSONWriter.cs" />
                 <Compile Include="JSON\JSONXmlReader.cs" />
                 <Compile Include="JSON\JSONXmlReaderOptions.cs" />
                 <Compile Include="JSON\StringTranslator.cs" />
                 <Compile Include="Parallels\DispatchPool.cs" />
                 <Compile Include="Parallels\ArrayTraits.cs" />
                 <Compile Include="Parallels\MTQueue.cs" />
                 <Compile Include="Parallels\WorkerPool.cs" />
                 <Compile Include="Parsing\Alphabet.cs" />
                 <Compile Include="Parsing\AlphabetBase.cs" />
                 <Compile Include="Parsing\AltToken.cs" />
                 <Compile Include="Parsing\BinaryToken.cs" />
                 <Compile Include="Parsing\CatToken.cs" />
                 <Compile Include="Parsing\CDFADefinition.cs" />
                 <Compile Include="Parsing\DFABuilder.cs" />
                 <Compile Include="Parsing\DFADefinitionBase.cs" />
                 <Compile Include="Parsing\DFAStateDescriptor.cs" />
                 <Compile Include="Parsing\DFAutomaton.cs" />
                 <Compile Include="Parsing\EDFADefinition.cs" />
                 <Compile Include="Parsing\EmptyToken.cs" />
                 <Compile Include="Parsing\EndToken.cs" />
                 <Compile Include="Parsing\EnumAlphabet.cs" />
                 <Compile Include="Parsing\Grammar.cs" />
                 <Compile Include="Parsing\IAlphabet.cs" />
                 <Compile Include="Parsing\IDFADefinition.cs" />
                 <Compile Include="Parsing\IVisitor.cs" />
                 <Compile Include="Parsing\ParserException.cs" />
                 <Compile Include="Parsing\Scanner.cs" />
                 <Compile Include="Parsing\StarToken.cs" />
                 <Compile Include="Parsing\SymbolToken.cs" />
                 <Compile Include="Parsing\Token.cs" />
-                <Compile Include="SafePool.cs" />
                 <Compile Include="ServiceLocator.cs" />
                 <Compile Include="TaskController.cs" />
                 <Compile Include="ProgressInitEventArgs.cs" />
                 <Compile Include="Properties\AssemblyInfo.cs" />
                 <Compile Include="Promise.cs" />
                 <Compile Include="Parallels\AsyncPool.cs" />
                 <Compile Include="Safe.cs" />
                 <Compile Include="ValueEventArgs.cs" />
                 <Compile Include="PromiseExtensions.cs" />
                 <Compile Include="TransientPromiseException.cs" />
                 <Compile Include="SyncContextPromise.cs" />
-                <Compile Include="ObjectPool.cs" />
                 <Compile Include="Diagnostics\OperationContext.cs" />
                 <Compile Include="Diagnostics\TraceContext.cs" />
                 <Compile Include="Diagnostics\LogEventArgs.cs" />
                 <Compile Include="Diagnostics\LogEventArgsT.cs" />
                 <Compile Include="Diagnostics\Extensions.cs" />
                 <Compile Include="IComponentContainer.cs" />
                 <Compile Include="PromiseEventType.cs" />
                 <Compile Include="Parallels\MTCustomQueue.cs" />
                 <Compile Include="Parallels\MTCustomQueueNode.cs" />
                 <Compile Include="ComponentContainer.cs" />
+                <Compile Include="DisposablePool.cs" />
+                <Compile Include="ObjectPool.cs" />
               </ItemGroup>
               <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
               <ItemGroup />
               <ProjectExtensions>
                 <MonoDevelop>
                   <Properties>
                     <Policies>
                       <CSharpFormattingPolicy IndentSwitchBody="True" NamespaceBraceStyle="EndOfLine" ClassBraceStyle="EndOfLine" InterfaceBraceStyle="EndOfLine" StructBraceStyle="EndOfLine" EnumBraceStyle="EndOfLine" MethodBraceStyle="EndOfLine" ConstructorBraceStyle="EndOfLine" DestructorBraceStyle="EndOfLine" BeforeMethodDeclarationParentheses="False" BeforeMethodCallParentheses="False" BeforeConstructorDeclarationParentheses="False" NewLineBeforeConstructorInitializerColon="NewLine" NewLineAfterConstructorInitializerColon="SameLine" BeforeIndexerDeclarationBracket="False" BeforeDelegateDeclarationParentheses="False" NewParentheses="False" SpacesBeforeBrackets="False" inheritsSet="Mono" inheritsScope="text/x-csharp" scope="text/x-csharp" />
                       <TextStylePolicy FileWidth="120" EolMarker="Unix" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/x-csharp" />
                       <DotNetNamingPolicy DirectoryNamespaceAssociation="PrefixedHierarchical" ResourceNamePolicy="MSBuild" />
                       <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="application/xml" />
                       <XmlFormattingPolicy inheritsSet="Mono" inheritsScope="application/xml" scope="application/xml" />
                       <TextStylePolicy FileWidth="120" TabsToSpaces="False" inheritsSet="VisualStudio" inheritsScope="text/plain" scope="text/plain" />
                       <NameConventionPolicy>
                         <Rules>
                           <NamingRule Name="Namespaces" AffectedEntity="Namespace" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Types" AffectedEntity="Class, Struct, Enum, Delegate" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Interfaces" AffectedEntity="Interface" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredPrefixes>
                               <String>I</String>
                             </RequiredPrefixes>
                           </NamingRule>
                           <NamingRule Name="Attributes" AffectedEntity="CustomAttributes" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredSuffixes>
                               <String>Attribute</String>
                             </RequiredSuffixes>
                           </NamingRule>
                           <NamingRule Name="Event Arguments" AffectedEntity="CustomEventArgs" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredSuffixes>
                               <String>EventArgs</String>
                             </RequiredSuffixes>
                           </NamingRule>
                           <NamingRule Name="Exceptions" AffectedEntity="CustomExceptions" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredSuffixes>
                               <String>Exception</String>
                             </RequiredSuffixes>
                           </NamingRule>
                           <NamingRule Name="Methods" AffectedEntity="Methods" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Static Readonly Fields" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Protected, Public" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True" />
                           <NamingRule Name="Fields (Non Private)" AffectedEntity="Field" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="ReadOnly Fields (Non Private)" AffectedEntity="ReadonlyField" VisibilityMask="Internal, Public" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False" />
                           <NamingRule Name="Fields (Private)" AffectedEntity="Field, ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False">
                             <RequiredPrefixes>
                               <String>m_</String>
                             </RequiredPrefixes>
                           </NamingRule>
                           <NamingRule Name="Static Fields (Private)" AffectedEntity="Field" VisibilityMask="Private" NamingStyle="CamelCase" IncludeInstanceMembers="False" IncludeStaticEntities="True">
                             <RequiredPrefixes>
                               <String>_</String>
                             </RequiredPrefixes>
                           </NamingRule>
                           <NamingRule Name="ReadOnly Fields (Private)" AffectedEntity="ReadonlyField" VisibilityMask="Private, Protected" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="False">
                             <RequiredPrefixes>
                               <String>m_</String>
                             </RequiredPrefixes>
                           </NamingRule>
                           <NamingRule Name="Constant Fields" AffectedEntity="ConstantField" VisibilityMask="VisibilityMask" NamingStyle="AllUpper" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Properties" AffectedEntity="Property" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Events" AffectedEntity="Event" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Enum Members" AffectedEntity="EnumMember" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Parameters" AffectedEntity="Parameter, LocalVariable" VisibilityMask="VisibilityMask" NamingStyle="CamelCase" IncludeInstanceMembers="True" IncludeStaticEntities="True" />
                           <NamingRule Name="Type Parameters" AffectedEntity="TypeParameter" VisibilityMask="VisibilityMask" NamingStyle="PascalCase" IncludeInstanceMembers="True" IncludeStaticEntities="True">
                             <RequiredPrefixes>
                               <String>T</String>
                             </RequiredPrefixes>
                           </NamingRule>
                         </Rules>
                       </NameConventionPolicy>
                     </Policies>
                   </Properties>
                 </MonoDevelop>
               </ProjectExtensions>
             </Project>

Implab/ObjectPool.cs +39 -69

@@ -1,90 +1,60
1	using System;	1	using Implab.Parallels;
2	using Implab.Parallels;	2	using System;
3	using System.Threading;	3	using System.Threading;
4	using System.Diagnostics;
5	using System.Diagnostics.CodeAnalysis;
6		4
7	namespace Implab {	5	namespace Implab {
8	public abstract class ObjectPool<T> : IDisposable {	6	/// <summary>
		7	/// Базовый класс для создания пулов объектов.
		8	/// </summary>
		9	/// <remarks>
		10	/// <para>Пул объектов позволяет многократно использовать один и тотже объект,
		11	/// что актуально для объектов, создание которых требует существенных ресурсов.
		12	/// Пул объектов использует слабые ссылки, чтобы не препятствовать освобождению
		13	/// ресурсов и создает новые объекты при необходимости.</para>
		14	/// <para>
		15	/// Наследники должны реализовывать метод <see cref="CreateInstance()"/> для создания
		16	/// новых экземпляров.
		17	/// </para>
		18	/// <para>Пул поддерживает обращения сразу из нескольких потоков.</para>
		19	/// </remarks>
		20	public abstract class ObjectPool<T> where T : class {
		21	readonly MTQueue<WeakReference> m_queue = new MTQueue<WeakReference>();
9	readonly int m_size;	22	readonly int m_size;
10	readonly MTQueue<T> m_queue = new MTQueue<T>();	23	int m_count = 0;
11		24
12	[SuppressMessage("Microsoft.Design", "CA1000:DoNotDeclareStaticMembersOnGenericTypes")]	25	protected ObjectPool() : this(Environment.ProcessorCount+1) {
13	static readonly bool _isValueType = typeof(T).IsValueType;
14		26
15	bool m_disposed;	27	}
16
17	int m_count;
18		28
19	protected ObjectPool(int size) {	29	protected ObjectPool(int size) {
20	m_size = size;	30	Safe.ArgumentInRange(size,1,size,"size");
21	}
22
23	protected ObjectPool() : this(Environment.ProcessorCount+1) {
24	}
25		31
26	public T Allocate() {	32	m_size = size;
27	if (m_disposed)
28	throw new ObjectDisposedException(ToString());
29
30	T instance;
31	if (m_queue.TryDequeue(out instance)) {
32	Interlocked.Decrement(ref m_count);
33	} else {
34	instance = CreateInstance();
35	Debug.Assert(!Object.Equals(instance, default(T)) \|\| _isValueType);
36	}
37	return instance;
38	}	33	}
39		34
40	protected abstract T CreateInstance();	35	protected abstract T CreateInstance();
41		36
42	protected virtual void CleanupInstance(T instance) {	37	protected virtual void CleanupInstance(T instance) {
43	}	38	}
44		39
45	public ~~void~~ ~~Release~~(T ~~instance~~) {	40	public T Allocate() {
46	if ( Object.Equals(instance,default(T)) && !_isValueType)	41	WeakReference reference;
47	return;	42	while (m_queue.TryDequeue(out reference)) {
48		43	Interlocked.Decrement(ref m_count);
49	Thread.MemoryBarrier();	44	object instance = reference.Target;
50	if (m_count < m_size && !m_disposed) {	45	if (instance == null)
51	Interlocked.Increment(ref m_count);	46	continue;
52		47	return (T)instance;
53	CleanupInstance(instance);	48	}
		49	return CreateInstance();
		50	}
54		51
55	m_queue.Enqueue(instance);	52	public void Release(T instance) {
56		53	if (m_count < m_size && instance != null) {
57	// пока элемент возвращался в кеш, была начата операция освобождения всего кеша	54	Interlocked.Increment(ref m_count);
58	// и возможно уже законцена, в таком случае следует извлечь элемент обратно и	55	CleanupInstance(instance);
59	// освободить его. Если операция освобождения кеша еще не заврешилась, то будет	56	m_queue.Enqueue(new WeakReference(instance));
60	// изъят и освобожден произвольный элемен, что не повлияет на ход всего процесса.
61	if (m_disposed && m_queue.TryDequeue(out instance) && instance is IDisposable)
62	((IDisposable)instance).Dispose() ;
63
64	} else {
65	if (instance is IDisposable)
66	((IDisposable)instance).Dispose();
67	}	57	}
68	}	58	}
69
70	protected virtual void Dispose(bool disposing) {
71	if (disposing) {
72	m_disposed = true;
73	T instance;
74	while (m_queue.TryDequeue(out instance))
75	if (instance is IDisposable)
76	((IDisposable)instance).Dispose();
77	}	59	}
78	}	60	}
79
80	#region IDisposable implementation
81
82	public void Dispose() {
83	Dispose(true);
84	GC.SuppressFinalize(this);
85	}
86
87	#endregion
88	}
89	}
90

Implab/ServiceLocator.cs +1 -1

             using System;
             using System.Collections.Generic;
             namespace Implab {
                 /// <summary>
                 /// Коллекция сервисов, позволяет регистрировать и получать сервисы.
                 /// </summary>
-                public class ServiceLocator: Component, IServiceLocator, IServiceProvider {
+                public class ServiceLocator: Disposable, IServiceLocator, IServiceProvider {
                     // запись о сервисе
                     struct ServiceEntry : IDisposable {
                         public object service; // сервис
                         public bool shared; // признак того, что сервис НЕ нужно освобождать
                         public Func<object> activator; // активатор сервиса при первом обращении
                         public Action<object> cleanup; // функция для очистки сервиса
                         public List<Type> associated; // ссылки на текущую запись
                         public Type origin; // ссылка на оригинальную запись о сервисе
                         #region IDisposable implementation
                         public void Dispose() {
                             if (shared)
                                 return;
                             if (cleanup != null) {
                                 if (service != null)
                                     cleanup(service);
                             } else
                                 Safe.Dispose(service);
                         }
                         #endregion
                     }
                     // словарь существующих сервисов
                     readonly Dictionary<Type, ServiceEntry> m_services = new Dictionary<Type,ServiceEntry>();
                     /// <summary>
                     /// Получает объект предоставляющий сервис <typeparamref name="T"/>.
                     /// </summary>
                     /// <typeparam name="T">Тип запрашиваемого сервиса</typeparam>
                     /// <returns>Объект, реализующий сервис</returns>
                     /// <exception cref="KeyNotFoundException">Сервис не зарегистрирован</exception>
                     public T GetService<T>() {
                         object result;
                         if (TryGetService(typeof(T), out result))
                             return (T)result;
                         throw new ApplicationException (String.Format ("{0} doesn't provide {1} service", this, typeof(T)));
                     }
                     /// <summary>
                     /// Пытается получить указанный сервис, в случае, если компонента не предоставляет требуемый сервис
                     /// не возникает исключений.
                     /// </summary>
                     /// <typeparam name="T">Тип требуемого сервиса.</typeparam>
                     /// <param name="service">Объект реализующий сервис, или <c>default(T)</c> если такового нет.</param>
                     /// <returns><c>true</c> - сервис найден, <c>false</c> - сервис не зарегистрирован.</returns>
                     public bool TryGetService<T>(out T service) {
                         object result;
                         if (TryGetService(typeof(T), out result)) {
                             service = (T)result;
                             return true;
                         }
                         service = default(T);
                         return false;
                     }
                     /// <summary>
                     /// Получает объект предоставляющий сервис <paramref name="serviceType"/>
                     /// </summary>
                     /// <param name="serviceType">Тип запрашиваемого сервиса</param>
                     /// <returns>Объект, реализующий сервис</returns>
                     /// <exception cref="KeyNotFoundException">Сервис не зарегистрирован</exception>
             		public object GetService(Type serviceType) {
                         object result;
                         if (TryGetService(serviceType, out result))
                             return result;
             			throw new ApplicationException (String.Format ("{0} doesn't provide {1} service", this, serviceType));
             		}
             		/// <summary>
             		/// Пытается получить требуемый сервис или совместимый с ним.
             		/// </summary>
             		/// <returns><c>true</c>, если сервис был найден, <c>false</c> в противном случае..</returns>
             		/// <param name="serviceType">Тип запрашиваемого сервиса.</param>
             		/// <param name="service">Искомый сервис.</param>
             		public virtual bool TryGetService(Type serviceType, out object service) {
                         Safe.ArgumentNotNull(serviceType, "serviceType");
                         AssertNotDisposed();
                         ServiceEntry se;
                         if (!m_services.TryGetValue(serviceType, out se)) {
                             // ищем ближайщий объект, реализующий нужный сервис
                             Type pt = null;
                             foreach (var t in m_services.Keys)
                                 if (serviceType.IsAssignableFrom(t) && (pt == null || t.IsAssignableFrom(pt)))
                                     pt = t;
             				if (pt == null) {
             					// нет нужного сервиса
             					service = null;
             					return false;
             				}
                             var pe = m_services[pt];
                             // найденная запись может ссылаться на оригинальную запись с сервисом
                             if(pe.origin != null) {
                                 pt = pe.origin;
                                 pe = m_services[pt];
                             }
                             // добавляем список с обратными ссылками
                             if (pe.associated == null)
                                 pe.associated = new List<Type>();
                             pe.associated.Add(serviceType);
                             // обновляем родительскую запись
                             m_services[pt] = pe;
                             // создаем запись со ссылкой
                             se = new ServiceEntry {
                                 service = pe.service,
                                 origin = pt,
                                 shared = true // предотвращаем множественные попытки освобождения
                             };
                             m_services[serviceType] = se;
                         }
                         // запись содержит в себе информацию о сервисе
             			if (se.service != null) {
             				service = se.service;
             				return true;
             			}
                         // текущая запись является ссылкой
                         if (se.origin != null) {
                             se.service = GetService(se.origin);
                             m_services[serviceType] = se;
             				service = se.service;
             				return true;
                         }
                         // текущая запись не является ссылкой и не имеет информации о сервисе
                         // она должна сожержать информацию об активации
                         if (se.activator != null) {
                             se.service = se.activator();
                             m_services[serviceType] = se;
             				service = se.service;
             				return true;
                         }
             			service = null;
             			return false;
                     }
                     /// <summary>
                     /// Регистрирует фабрику для активации сервиса по первому требованию.
                     /// </summary>
                     /// <typeparam name="T">Тип регистрируемого сервиса.</typeparam>
                     /// <param name="activator">Фабрика для создания/получения объекта, предоставляющего сервис.</param>
                     /// <param name = "cleanup">Метод для освобождения экземпляра сервиса, будет вызыван при освобождении сервис-локатора.</param>
                     /// <remarks>При освобождении сервис-локатора, сервисы полученные в результате активации также будут освобождены.</remarks>
                     public void Register<T>(Func<T> activator, Action<T> cleanup) {
                         Safe.ArgumentNotNull(activator, "activator");
                         AssertNotDisposed();
                         Unregister(typeof(T));
                         var serviceEntry = new ServiceEntry();
                         serviceEntry.activator = () => activator();
                         if (cleanup != null)
                             serviceEntry.cleanup = instance => cleanup((T)instance);
                         m_services[typeof(T)] = serviceEntry;
                     }
                     public void Register<T>(Func<T> activator) {
                         Register(activator, null);
                     }
                     /// <summary>
                     /// Регистрирует объект, предоставляющий сервис.
                     /// </summary>
                     /// <typeparam name="T">Тип регистрируемого сервиса.</typeparam>
                     /// <param name="service">Объект, предоставляющий сервис.</param>
                     /// <exception cref="InvalidOperationException">Указанный сервис уже зарегистрирован.</exception>
                     /// <remarks>Сервис-локатором не управляет временем жизни объекта для зарегистрированного сервиса.</remarks>
                     public void Register<T>(T service) {
                         Register(service, true);
                     }
                     /// <summary>
                     /// Регистрирует объект, предоставляющий сервис. Повторная регистрация отменяет уже существующую.
                     /// </summary>
                     /// <typeparam name="T">Тип регистрируемого сервиса.</typeparam>
                     /// <param name="service">Объект, предоставляющий сервис.</param>
                     /// <param name="shared">Признак того, что объект является разделяемым и сервис-локатор не должен его освобождать.</param>
                     public void Register<T>(T service, bool shared) {
                         Safe.ArgumentNotNull(service, "service");
                         AssertNotDisposed();
                         Unregister(typeof(T));
                         m_services[typeof(T)] = new ServiceEntry { service = service, shared = shared };
                     }
                     public void Unregister(Type serviceType) {
                         Safe.ArgumentNotNull(serviceType, "serviceType");
                         AssertNotDisposed();
                         ServiceEntry se;
                         if (m_services.TryGetValue(serviceType, out se)) {
                             if (se.origin != null) {
                                 var pe = m_services[se.origin];
                                 pe.associated.Remove(serviceType);
                             }
                             // освобождаем ресурсы
                             se.Dispose();
                             m_services.Remove(serviceType);
                             // убираем связанные записи
                             if (se.associated != null)
                                 foreach (var item in se.associated)
                                     m_services.Remove(item);
                         }
                     }
                     /// <summary>
                     /// Освобождает зарегистрированные сервисы (которые требуется освобоить).
                     /// </summary>
                     /// <param name="disposing">Призанак того, что нужно освободить ресурсы.</param>
                     protected override void Dispose(bool disposing) {
                         if (disposing) {
                             foreach (var entry in m_services.Values)
                                 entry.Dispose();
                         }
                         base.Dispose(disposing);
                     }
                 }
             }

Implab/SafePool.cs removed 0 -40

NO CONTENT: file was removed

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages