Mercurial > pub > ImplabNet
annotate Implab/ServiceLocator.cs @ 81:2c5631b43c7d v2
dispatch pool rewritten
| author | cin |
|---|---|
| date | Fri, 26 Sep 2014 20:44:01 +0400 |
| parents | 48763f3b5db8 |
| children | b33832ab0262 |
| rev | line source |
|---|---|
| 40 | 1 using System; |
| 2 using System.Collections.Generic; | |
| 3 using System.Linq; | |
| 4 using System.Web; | |
| 69 | 5 using System.Diagnostics; |
| 40 | 6 |
| 7 namespace Implab { | |
| 8 /// <summary> | |
| 9 /// Коллекция сервисов, позволяет регистрировать и получать сервисы. | |
| 10 /// </summary> | |
| 11 public class ServiceLocator: Component, IServiceLocator, IServiceProvider { | |
| 12 // запись об сервисе | |
| 13 struct ServiceEntry { | |
| 14 public object service; // сервис | |
| 15 public bool shared; // признак того, что сервис НЕ нужно освобождать | |
| 16 public Func<object> activator; // активатор сервиса при первом обращении | |
| 17 public List<Type> associated; // ссылки на текущую запись | |
| 18 public Type origin; // ссылка на оригинальную запись о сервисе | |
| 19 } | |
| 20 | |
| 21 // словарь существующих сервисов | |
| 69 | 22 readonly Dictionary<Type, ServiceEntry> m_services = new Dictionary<Type,ServiceEntry>(); |
| 40 | 23 |
| 24 /// <summary> | |
| 25 /// Получает объект предоставляющий сервис <typeparamref name="T"/>. | |
| 26 /// </summary> | |
| 27 /// <typeparam name="T">Тип запрашиваемого сервиса</typeparam> | |
| 28 /// <returns>Объект, реализующий сервис</returns> | |
| 29 /// <exception cref="KeyNotFoundException">Сервис не зарегистрирован</exception> | |
| 30 public T GetService<T>() { | |
| 69 | 31 object result; |
| 32 if (TryGetService(typeof(T), out result)) | |
| 33 return (T)result; | |
| 34 throw new ApplicationException (String.Format ("{0} doesn't provide {1} service", this, typeof(T))); | |
| 40 | 35 } |
| 36 | |
| 37 | |
| 38 /// <summary> | |
| 39 /// Пытается получить указанный сервис, в случае, если компонента не предоставляет требуемый сервис | |
| 40 /// не возникает исключений. | |
| 41 /// </summary> | |
| 42 /// <typeparam name="T">Тип требуемого сервиса.</typeparam> | |
| 43 /// <param name="service">Объект реализующий сервис, или <c>default(T)</c> если такового нет.</param> | |
| 44 /// <returns><c>true</c> - сервис найден, <c>false</c> - сервис не зарегистрирован.</returns> | |
| 45 public bool TryGetService<T>(out T service) { | |
| 69 | 46 object result; |
| 47 if (TryGetService(typeof(T), out result)) { | |
| 48 service = (T)result; | |
| 49 return true; | |
| 50 } | |
| 51 service = default(T); | |
| 52 return false; | |
| 40 | 53 } |
| 54 | |
| 55 /// <summary> | |
| 56 /// Получает объект предоставляющий сервис <paramref name="serviceType"/> | |
| 57 /// </summary> | |
| 58 /// <param name="serviceType">Тип запрашиваемого сервиса</param> | |
| 59 /// <returns>Объект, реализующий сервис</returns> | |
| 60 /// <exception cref="KeyNotFoundException">Сервис не зарегистрирован</exception> | |
|
68
9dd6a896a385
ServiceLocator: small refactoring, GetService method is made virtual
cin
parents:
40
diff
changeset
|
61 public object GetService(Type serviceType) { |
| 69 | 62 object result; |
| 63 if (TryGetService(serviceType, out result)) | |
| 64 return result; | |
| 65 throw new ApplicationException (String.Format ("{0} doesn't provide {1} service", this, serviceType)); | |
|
68
9dd6a896a385
ServiceLocator: small refactoring, GetService method is made virtual
cin
parents:
40
diff
changeset
|
66 } |
|
9dd6a896a385
ServiceLocator: small refactoring, GetService method is made virtual
cin
parents:
40
diff
changeset
|
67 |
| 69 | 68 /// <summary> |
| 69 /// Пытается получить требуемый сервис или совместимый с ним. | |
| 70 /// </summary> | |
| 71 /// <returns><c>true</c>, если сервис был найден, <c>false</c> в противном случае..</returns> | |
| 72 /// <param name="serviceType">Тип запрашиваемого сервиса.</param> | |
| 73 /// <param name="service">Искомый сервис.</param> | |
| 74 public virtual bool TryGetService(Type serviceType, out object service) { | |
| 40 | 75 if (serviceType == null) |
| 76 throw new ArgumentNullException("serviceType"); | |
| 77 AssertNotDisposed(); | |
| 78 | |
| 79 ServiceEntry se; | |
| 80 if (!m_services.TryGetValue(serviceType, out se)) { | |
| 81 // ищем ближайщий объект, реализующий нужный сервис | |
| 82 Type pt = null; | |
| 83 foreach (var t in m_services.Keys) | |
| 84 if (serviceType.IsAssignableFrom(t) && (pt == null || t.IsAssignableFrom(pt))) | |
| 85 pt = t; | |
| 69 | 86 |
| 87 if (pt == null) { | |
| 88 // нет нужного сервиса | |
| 89 service = null; | |
| 90 return false; | |
| 91 } | |
| 40 | 92 |
| 93 var pe = m_services[pt]; | |
| 94 | |
| 95 // найденная запись может ссылаться на оригинальную запись с сервисом | |
| 96 if(pe.origin != null) { | |
| 97 pt = pe.origin; | |
| 98 pe = m_services[pt]; | |
| 99 } | |
| 100 | |
| 101 // добавляем список с обратными ссылками | |
| 102 if (pe.associated == null) | |
| 103 pe.associated = new List<Type>(); | |
| 104 | |
| 105 pe.associated.Add(serviceType); | |
| 106 | |
| 107 // обновляем родительскую запись | |
| 108 m_services[pt] = pe; | |
| 109 | |
| 110 // создаем запись со ссылкой | |
| 111 se = new ServiceEntry { | |
| 112 service = pe.service, | |
| 113 origin = pt, | |
| 114 shared = true // предотвращаем множественные попытки освобождения | |
| 115 }; | |
| 116 | |
| 117 m_services[serviceType] = se; | |
| 118 } | |
| 119 | |
| 120 // запись содержит в себе информацию о сервисе | |
| 69 | 121 if (se.service != null) { |
| 122 service = se.service; | |
| 123 return true; | |
| 124 } | |
| 40 | 125 |
| 126 // текущая запись является ссылкой | |
| 127 if (se.origin != null) { | |
| 128 se.service = GetService(se.origin); | |
| 129 m_services[serviceType] = se; | |
| 69 | 130 service = se.service; |
| 131 return true; | |
| 40 | 132 } |
| 133 | |
| 134 // текущая запись не является ссылкой и не имеет информации о сервисе | |
| 135 // она должна сожержать информацию об активации | |
| 136 if (se.activator != null) { | |
| 137 se.service = se.activator(); | |
| 138 | |
| 139 m_services[serviceType] = se; | |
| 140 | |
| 69 | 141 service = se.service; |
| 142 return true; | |
| 40 | 143 } |
| 144 | |
| 69 | 145 service = null; |
| 146 return false; | |
| 40 | 147 } |
| 148 | |
| 149 /// <summary> | |
| 150 /// Регистрирует фабрику для активации сервиса по первому требованию. | |
| 151 /// </summary> | |
| 152 /// <typeparam name="T">Тип регистрируемого сервиса.</typeparam> | |
| 153 /// <param name="activator">Фабрика для создания/получения объекта, предоставляющего сервис.</param> | |
| 154 /// <exception cref="InvalidOperationException">Указанный сервис уже зарегистрирован.</exception> | |
| 155 /// <remarks>При освобождении сервис-локатора, сервисы полученные в результате активации также будут освобождены.</remarks> | |
| 156 public void Register<T>(Func<T> activator) { | |
| 157 if (activator == null) | |
| 158 throw new ArgumentNullException("activator"); | |
| 159 | |
| 160 AssertNotDisposed(); | |
| 161 | |
| 162 Unregister(typeof(T)); | |
| 163 | |
| 164 m_services[typeof(T)] = new ServiceEntry { | |
| 165 activator = () => activator() as object | |
| 166 }; | |
| 167 } | |
| 168 | |
| 169 /// <summary> | |
| 170 /// Регистрирует объект, предоставляющий сервис. | |
| 171 /// </summary> | |
| 172 /// <typeparam name="T">Тип регистрируемого сервиса.</typeparam> | |
| 173 /// <param name="service">Объект, предоставляющий сервис.</param> | |
| 174 /// <exception cref="InvalidOperationException">Указанный сервис уже зарегистрирован.</exception> | |
| 175 /// <remarks>Сервис-локатором не управляет временем жизни объекта для зарегистрированного сервиса.</remarks> | |
| 176 public void Register<T>(T service) { | |
| 177 Register(service, true); | |
| 178 } | |
| 179 | |
| 180 /// <summary> | |
| 181 /// Регистрирует объект, предоставляющий сервис. | |
| 182 /// </summary> | |
| 183 /// <typeparam name="T">Тип регистрируемого сервиса.</typeparam> | |
| 184 /// <param name="service">Объект, предоставляющий сервис.</param> | |
| 185 /// <param name="shared">Признак того, что объект является разделяемым и сервис-локатор не должен его освобождать.</param> | |
| 186 /// <exception cref="InvalidOperationException">Указанный сервис уже зарегистрирован.</exception> | |
| 187 public void Register<T>(T service, bool shared) { | |
| 188 if (service == null) | |
| 189 throw new ArgumentNullException("service"); | |
| 190 | |
| 191 AssertNotDisposed(); | |
| 192 | |
| 193 Unregister(typeof(T)); | |
| 194 | |
| 195 m_services[typeof(T)] = new ServiceEntry { service = service, shared = shared }; | |
| 196 } | |
| 197 | |
| 198 public void Unregister(Type serviceType) { | |
| 199 if (serviceType == null) | |
| 200 throw new ArgumentNullException("serviceType"); | |
| 201 | |
| 202 AssertNotDisposed(); | |
| 203 | |
| 204 ServiceEntry se; | |
| 205 if (m_services.TryGetValue(serviceType, out se)) { | |
| 206 // освобождаем ресурсы | |
| 207 if (se.service != null && !se.shared) | |
| 208 ((IDisposable)se.service).Dispose(); | |
| 209 m_services.Remove(serviceType); | |
| 210 | |
| 211 // убираем связанные записи | |
| 212 if (se.associated != null) | |
| 213 foreach (var item in se.associated) | |
| 214 m_services.Remove(item); | |
| 215 } | |
| 216 } | |
| 217 | |
| 218 /// <summary> | |
| 219 /// Освобождает зарегистрированные сервисы (которые требуется освобоить). | |
| 220 /// </summary> | |
| 221 /// <param name="disposing">Призанак того, что нужно освободить ресурсы.</param> | |
| 222 protected override void Dispose(bool disposing) { | |
| 223 if (disposing) { | |
| 224 | |
| 225 foreach (var entry in m_services.Values) | |
| 226 if (!entry.shared && entry.service is IDisposable) | |
| 227 ((IDisposable)entry.service).Dispose(); | |
| 228 | |
| 229 } | |
| 230 base.Dispose(disposing); | |
| 231 } | |
| 232 } | |
| 233 } |