ReferencePool.ReferenceCollection.cs 5.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202
  1. //------------------------------------------------------------
  2. // Game Framework
  3. // Copyright © 2013-2021 loyalsoft. All rights reserved.
  4. // Homepage: http://www.game7000.com/
  5. // Feedback: http://www.game7000.com/
  6. //------------------------------------------------------------
  7. using System;
  8. using System.Collections.Generic;
  9. namespace GameFramework
  10. {
  11. public static partial class ReferencePool
  12. {
  13. private sealed class ReferenceCollection
  14. {
  15. private readonly Queue<IReference> m_References;
  16. private readonly Type m_ReferenceType;
  17. private int m_UsingReferenceCount;
  18. private int m_AcquireReferenceCount;
  19. private int m_ReleaseReferenceCount;
  20. private int m_AddReferenceCount;
  21. private int m_RemoveReferenceCount;
  22. public ReferenceCollection(Type referenceType)
  23. {
  24. m_References = new Queue<IReference>();
  25. m_ReferenceType = referenceType;
  26. m_UsingReferenceCount = 0;
  27. m_AcquireReferenceCount = 0;
  28. m_ReleaseReferenceCount = 0;
  29. m_AddReferenceCount = 0;
  30. m_RemoveReferenceCount = 0;
  31. }
  32. public Type ReferenceType
  33. {
  34. get
  35. {
  36. return m_ReferenceType;
  37. }
  38. }
  39. public int UnusedReferenceCount
  40. {
  41. get
  42. {
  43. return m_References.Count;
  44. }
  45. }
  46. public int UsingReferenceCount
  47. {
  48. get
  49. {
  50. return m_UsingReferenceCount;
  51. }
  52. }
  53. public int AcquireReferenceCount
  54. {
  55. get
  56. {
  57. return m_AcquireReferenceCount;
  58. }
  59. }
  60. public int ReleaseReferenceCount
  61. {
  62. get
  63. {
  64. return m_ReleaseReferenceCount;
  65. }
  66. }
  67. public int AddReferenceCount
  68. {
  69. get
  70. {
  71. return m_AddReferenceCount;
  72. }
  73. }
  74. public int RemoveReferenceCount
  75. {
  76. get
  77. {
  78. return m_RemoveReferenceCount;
  79. }
  80. }
  81. public T Acquire<T>() where T : class, IReference, new()
  82. {
  83. if (typeof(T) != m_ReferenceType)
  84. {
  85. throw new GameFrameworkException("Type is invalid.");
  86. }
  87. m_UsingReferenceCount++;
  88. m_AcquireReferenceCount++;
  89. lock (m_References)
  90. {
  91. if (m_References.Count > 0)
  92. {
  93. return (T)m_References.Dequeue();
  94. }
  95. }
  96. m_AddReferenceCount++;
  97. return new T();
  98. }
  99. public IReference Acquire()
  100. {
  101. m_UsingReferenceCount++;
  102. m_AcquireReferenceCount++;
  103. lock (m_References)
  104. {
  105. if (m_References.Count > 0)
  106. {
  107. return m_References.Dequeue();
  108. }
  109. }
  110. m_AddReferenceCount++;
  111. return (IReference)Activator.CreateInstance(m_ReferenceType);
  112. }
  113. public void Release(IReference reference)
  114. {
  115. reference.Clear();
  116. lock (m_References)
  117. {
  118. if (m_EnableStrictCheck && m_References.Contains(reference))
  119. {
  120. throw new GameFrameworkException("The reference has been released.");
  121. }
  122. m_References.Enqueue(reference);
  123. }
  124. m_ReleaseReferenceCount++;
  125. m_UsingReferenceCount--;
  126. }
  127. public void Add<T>(int count) where T : class, IReference, new()
  128. {
  129. if (typeof(T) != m_ReferenceType)
  130. {
  131. throw new GameFrameworkException("Type is invalid.");
  132. }
  133. lock (m_References)
  134. {
  135. m_AddReferenceCount += count;
  136. while (count-- > 0)
  137. {
  138. m_References.Enqueue(new T());
  139. }
  140. }
  141. }
  142. public void Add(int count)
  143. {
  144. lock (m_References)
  145. {
  146. m_AddReferenceCount += count;
  147. while (count-- > 0)
  148. {
  149. m_References.Enqueue((IReference)Activator.CreateInstance(m_ReferenceType));
  150. }
  151. }
  152. }
  153. public void Remove(int count)
  154. {
  155. lock (m_References)
  156. {
  157. if (count > m_References.Count)
  158. {
  159. count = m_References.Count;
  160. }
  161. m_RemoveReferenceCount += count;
  162. while (count-- > 0)
  163. {
  164. m_References.Dequeue();
  165. }
  166. }
  167. }
  168. public void RemoveAll()
  169. {
  170. lock (m_References)
  171. {
  172. m_RemoveReferenceCount += m_References.Count;
  173. m_References.Clear();
  174. }
  175. }
  176. }
  177. }
  178. }