From dc914b18064b1a2f4f544774f81c2c449e5428ac Mon Sep 17 00:00:00 2001
From: orignal <i2porignal@yandex.ru>
Date: Mon, 16 Jan 2017 15:40:01 -0500
Subject: [PATCH] multithreaded memory pool

---
 util.h | 36 +++++++++++++++++++++++++++++++++++-
 1 file changed, 35 insertions(+), 1 deletion(-)

diff --git a/util.h b/util.h
index 3b30919e..2ee1c286 100644
--- a/util.h
+++ b/util.h
@@ -4,6 +4,7 @@
 #include <string>
 #include <functional>
 #include <memory>
+#include <mutex>
 #include <boost/asio.hpp>
 
 #ifdef ANDROID
@@ -71,11 +72,44 @@ namespace util
 					std::bind (&MemoryPool<T>::Release, this, std::placeholders::_1));
 			}
 			
-		private:
+		protected:
 
 			T * m_Head;
 	};	
 
+	template<class T>
+	class MemoryPoolMt: public MemoryPool<T>
+	{
+		public:
+
+			MemoryPoolMt () {};			
+			template<typename... TArgs>
+			T * AcquireMt (TArgs&&... args)
+			{
+				if (!this->m_Head) return new T(args...);
+				std::lock_guard<std::mutex> l(m_Mutex);
+				return this->Acquire (args...);
+			}
+
+			void ReleaseMt (T * t)
+			{
+				std::lock_guard<std::mutex> l(m_Mutex);
+				this->Release (t);	
+			}
+
+			template<template<typename, typename...>class C, typename... R>
+			void ReleaseMt(const C<T *, R...>& c)	
+			{
+				std::lock_guard<std::mutex> l(m_Mutex);
+				for (auto& it: c)
+					this->Release (it);
+			}	
+
+		private:
+		
+			std::mutex m_Mutex;
+	};
+
 	namespace net
 	{
 		int GetMTU (const boost::asio::ip::address& localAddress);