implab/ImplabNet Files · Implab/ObjectPool.cs

fixed timeout handling in promises

cin - - Load All Authors

File last commit:

r119:2573b562e328 v2


                r148:e6d4b41f0101

Download file

             ObjectPool.cs
        
                    60 lines
            
             | 2.4 KiB
            
                | text/x-csharp
            
             |
                CSharpLexer
            
             / Implab / ObjectPool.cs
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      using Implab.Parallels;

      using System;

      using System.Threading;

      namespace Implab {

          /// <summary>

          /// Базовый класс для создания пулов объектов.

          /// </summary>

          /// <remarks>

          /// <para>Пул объектов позволяет многократно использовать один и тотже объект,

          /// что актуально для объектов, создание которых требует существенных ресурсов.

          /// Пул объектов использует слабые ссылки, чтобы не препятствовать освобождению

          /// ресурсов и создает новые объекты при необходимости.</para>

          /// <para>

          /// Наследники должны реализовывать метод <see cref="CreateInstance()"/> для создания

          /// новых экземпляров.

          /// </para>

          /// <para>Пул поддерживает обращения сразу из нескольких потоков.</para>

          /// </remarks>

          public abstract class ObjectPool<T> where T : class {

              readonly AsyncQueue<WeakReference> m_queue = new AsyncQueue<WeakReference>();

              readonly int m_size;

              int m_count = 0;

              protected ObjectPool() : this(Environment.ProcessorCount+1) {

              }

              protected ObjectPool(int size) {

                  Safe.ArgumentInRange(size,1,size,"size");

                  m_size = size;

              }

              protected abstract T CreateInstance();

              protected virtual void CleanupInstance(T instance) {

              }

              public T Allocate() {

                  WeakReference reference;

                  while (m_queue.TryDequeue(out reference)) {

                      Interlocked.Decrement(ref m_count);

                      object instance = reference.Target;

                      if (instance == null)

                          continue;

                      return (T)instance;

                  }

                  return CreateInstance();

              }

              public void Release(T instance) {

                  if (m_count < m_size && instance != null) {

                      Interlocked.Increment(ref m_count);

                      CleanupInstance(instance);

                      m_queue.Enqueue(new WeakReference(instance));

                  }

              }

          }

      }

	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

				using Implab.Parallels;
				using System;
				using System.Threading;

				namespace Implab {
				/// <summary>
				/// Базовый класс для создания пулов объектов.
				/// </summary>
				/// <remarks>
				/// <para>Пул объектов позволяет многократно использовать один и тотже объект,
				/// что актуально для объектов, создание которых требует существенных ресурсов.
				/// Пул объектов использует слабые ссылки, чтобы не препятствовать освобождению
				/// ресурсов и создает новые объекты при необходимости.</para>
				/// <para>
				/// Наследники должны реализовывать метод <see cref="CreateInstance()"/> для создания
				/// новых экземпляров.
				/// </para>
				/// <para>Пул поддерживает обращения сразу из нескольких потоков.</para>
				/// </remarks>
				public abstract class ObjectPool<T> where T : class {
				readonly AsyncQueue<WeakReference> m_queue = new AsyncQueue<WeakReference>();
				readonly int m_size;
				int m_count = 0;

				protected ObjectPool() : this(Environment.ProcessorCount+1) {

				}

				protected ObjectPool(int size) {
				Safe.ArgumentInRange(size,1,size,"size");

				m_size = size;
				}

				protected abstract T CreateInstance();

				protected virtual void CleanupInstance(T instance) {
				}

				public T Allocate() {
				WeakReference reference;
				while (m_queue.TryDequeue(out reference)) {
				Interlocked.Decrement(ref m_count);
				object instance = reference.Target;
				if (instance == null)
				continue;
				return (T)instance;
				}
				return CreateInstance();
				}

				public void Release(T instance) {
				if (m_count < m_size && instance != null) {
				Interlocked.Increment(ref m_count);
				CleanupInstance(instance);
				m_queue.Enqueue(new WeakReference(instance));
				}
				}
				}
				}