[C#/COMMON] 리소스 풀(Resource Pool) 사용하기

TestProject.zip

0.01MB

▶ ResourcePool.cs

using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Threading;

namespace TestProject
{
    /// <summary>
    /// 리소스 풀
    /// </summary>
    /// <typeparam name="TResource">리소스 타입</typeparam>
    public class ResourcePool<TResource>
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 병렬 백
        /// </summary>
        private readonly ConcurrentBag<TResource> concurrentBag = new ConcurrentBag<TResource>();

        /// <summary>
        /// 수동 리셋 이벤트
        /// </summary>
        private ManualResetEvent manualResetEvent = new ManualResetEvent(true);

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - ResourcePool(resourceList)

        /// <summary>
        /// 생성자
        /// </summary>
        /// <param name="resourceList">리소스 리스트</param>
        public ResourcePool(List<TResource> resourceList)
        {
            var enumerator = resourceList.GetEnumerator();

            while(enumerator.MoveNext())
            {
                this.concurrentBag.Add(enumerator.Current);
            }
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 구하기 - Get()

        /// <summary>
        /// 구하기
        /// </summary>
        /// <returns>리소스</returns>
        public TResource Get()
        {
            TResource resource;

            do
            {
                if(this.concurrentBag.IsEmpty)
                {
                    this.manualResetEvent.Reset();

                    this.manualResetEvent.WaitOne();
                }
            }
            while(!this.concurrentBag.TryTake(out resource));
            
            return resource;
        }

        #endregion
        #region 해제하기 - Release(resource)

        /// <summary>
        /// 해제하기
        /// </summary>
        /// <param name="resource">리소스</param>
        public void Release(TResource resource)
        {
            this.concurrentBag.Add(resource);

            this.manualResetEvent.Set();
        }

        #endregion
    }
}

 

728x90

 

▶ Resource.cs

namespace TestProject
{
    /// <summary>
    /// 리소스
    /// </summary>
    public class Resource
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 카운트
        /// </summary>
        private int count = 0;

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Property
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region ID - ID

        /// <summary>
        /// ID
        /// </summary>
        public int ID { get; set; }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 생성자 - Resource(id)

        /// <summary>
        /// 생성자
        /// </summary>
        /// <param name="id">ID</param>
        public Resource(int id)
        {
            ID = id;
        }

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 카운트 증가시키기 - IncreasegCount()

        /// <summary>
        /// 카운트 증가시키기
        /// </summary>
        public void IncreasegCount()
        {
            this.count++;
        }

        #endregion
        #region 문자열 구하기 - ToString()

        /// <summary>
        /// 문자열 구하기
        /// </summary>
        /// <returns>문자열</returns>
        public override string ToString()
        {
            return $"ID : {ID}, Count : {this.count}";
        }

        #endregion
    }
}

 

300x250

 

▶ Program.cs

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        private static void Main()
        {
            List<Resource> resourceList = new List<Resource>()
            {
                new Resource(0),
                new Resource(1),
                new Resource(2),
                new Resource(3)
            };

            ResourcePool<Resource> resourcePool = new ResourcePool<Resource>(resourceList);

            Parallel.For
            (
                1,
                50,
                new ParallelOptions { MaxDegreeOfParallelism = 8 },
                (int index) => {

                    Resource resource = resourcePool.Get();

                    resource.IncreasegCount();

                    Console.WriteLine($"[스레드 인덱스 : {index}] {resource.ToString()}");

                    Thread.Sleep(new Random().Next(600, 3000));

                    resourcePool.Release(resource);
                }
            );
        }

        #endregion
    }
}