using System; using System.Collections.Generic; namespace Implab { /// /// Коллекция сервисов, позволяет регистрировать и получать сервисы. /// public class ServiceLocator: Component, IServiceLocator, IServiceProvider { // запись о сервисе struct ServiceEntry : IDisposable { public object service; // сервис public bool shared; // признак того, что сервис НЕ нужно освобождать public Func activator; // активатор сервиса при первом обращении public Action cleanup; // функция для очистки сервиса public List associated; // ссылки на текущую запись public Type origin; // ссылка на оригинальную запись о сервисе #region IDisposable implementation public void Dispose() { if (shared) return; if (cleanup != null) { if (service != null) cleanup(service); } else Safe.Dispose(service); } #endregion } // словарь существующих сервисов readonly Dictionary m_services = new Dictionary(); /// /// Получает объект предоставляющий сервис . /// /// Тип запрашиваемого сервиса /// Объект, реализующий сервис /// Сервис не зарегистрирован public T GetService() { object result; if (TryGetService(typeof(T), out result)) return (T)result; throw new ApplicationException (String.Format ("{0} doesn't provide {1} service", this, typeof(T))); } /// /// Пытается получить указанный сервис, в случае, если компонента не предоставляет требуемый сервис /// не возникает исключений. /// /// Тип требуемого сервиса. /// Объект реализующий сервис, или default(T) если такового нет. /// true - сервис найден, false - сервис не зарегистрирован. public bool TryGetService(out T service) { object result; if (TryGetService(typeof(T), out result)) { service = (T)result; return true; } service = default(T); return false; } /// /// Получает объект предоставляющий сервис /// /// Тип запрашиваемого сервиса /// Объект, реализующий сервис /// Сервис не зарегистрирован public object GetService(Type serviceType) { object result; if (TryGetService(serviceType, out result)) return result; throw new ApplicationException (String.Format ("{0} doesn't provide {1} service", this, serviceType)); } /// /// Пытается получить требуемый сервис или совместимый с ним. /// /// true, если сервис был найден, false в противном случае.. /// Тип запрашиваемого сервиса. /// Искомый сервис. public virtual bool TryGetService(Type serviceType, out object service) { Safe.ArgumentNotNull(serviceType, "serviceType"); AssertNotDisposed(); ServiceEntry se; if (!m_services.TryGetValue(serviceType, out se)) { // ищем ближайщий объект, реализующий нужный сервис Type pt = null; foreach (var t in m_services.Keys) if (serviceType.IsAssignableFrom(t) && (pt == null || t.IsAssignableFrom(pt))) pt = t; if (pt == null) { // нет нужного сервиса service = null; return false; } var pe = m_services[pt]; // найденная запись может ссылаться на оригинальную запись с сервисом if(pe.origin != null) { pt = pe.origin; pe = m_services[pt]; } // добавляем список с обратными ссылками if (pe.associated == null) pe.associated = new List(); pe.associated.Add(serviceType); // обновляем родительскую запись m_services[pt] = pe; // создаем запись со ссылкой se = new ServiceEntry { service = pe.service, origin = pt, shared = true // предотвращаем множественные попытки освобождения }; m_services[serviceType] = se; } // запись содержит в себе информацию о сервисе if (se.service != null) { service = se.service; return true; } // текущая запись является ссылкой if (se.origin != null) { se.service = GetService(se.origin); m_services[serviceType] = se; service = se.service; return true; } // текущая запись не является ссылкой и не имеет информации о сервисе // она должна сожержать информацию об активации if (se.activator != null) { se.service = se.activator(); m_services[serviceType] = se; service = se.service; return true; } service = null; return false; } /// /// Регистрирует фабрику для активации сервиса по первому требованию. /// /// Тип регистрируемого сервиса. /// Фабрика для создания/получения объекта, предоставляющего сервис. /// Метод для освобождения экземпляра сервиса, будет вызыван при освобождении сервис-локатора. /// При освобождении сервис-локатора, сервисы полученные в результате активации также будут освобождены. public void Register(Func activator, Action cleanup) { Safe.ArgumentNotNull(activator, "activator"); AssertNotDisposed(); Unregister(typeof(T)); var serviceEntry = new ServiceEntry(); serviceEntry.activator = () => activator(); if (cleanup != null) serviceEntry.cleanup = instance => cleanup((T)instance); m_services[typeof(T)] = serviceEntry; } public void Register(Func activator) { Register(activator, null); } /// /// Регистрирует объект, предоставляющий сервис. /// /// Тип регистрируемого сервиса. /// Объект, предоставляющий сервис. /// Указанный сервис уже зарегистрирован. /// Сервис-локатором не управляет временем жизни объекта для зарегистрированного сервиса. public void Register(T service) { Register(service, true); } /// /// Регистрирует объект, предоставляющий сервис. Повторная регистрация отменяет уже существующую. /// /// Тип регистрируемого сервиса. /// Объект, предоставляющий сервис. /// Признак того, что объект является разделяемым и сервис-локатор не должен его освобождать. public void Register(T service, bool shared) { Safe.ArgumentNotNull(service, "service"); AssertNotDisposed(); Unregister(typeof(T)); m_services[typeof(T)] = new ServiceEntry { service = service, shared = shared }; } public void Unregister(Type serviceType) { Safe.ArgumentNotNull(serviceType, "serviceType"); AssertNotDisposed(); ServiceEntry se; if (m_services.TryGetValue(serviceType, out se)) { if (se.origin != null) { var pe = m_services[se.origin]; pe.associated.Remove(serviceType); } // освобождаем ресурсы se.Dispose(); m_services.Remove(serviceType); // убираем связанные записи if (se.associated != null) foreach (var item in se.associated) m_services.Remove(item); } } /// /// Освобождает зарегистрированные сервисы (которые требуется освобоить). /// /// Призанак того, что нужно освободить ресурсы. protected override void Dispose(bool disposing) { if (disposing) { foreach (var entry in m_services.Values) entry.Dispose(); } base.Dispose(disposing); } } }