StructureMap 'conditional singleton' dla Lucene.Net IndexReader

Question

Mam obiekt bezpieczny dla wątków, który jest drogi w tworzeniu i musi być dostępny za pośrednictwem mojej aplikacji (Lucene.Net IndexReader).

Obiekt może stać się nieważny, w którym to momencie muszę go odtworzyć (IndexReader.IsCurrent jest fałszywy, potrzebuję nowej instancji za pomocą IndexReader.Reopen).

Chciałbym móc użyć kontenera IoC (StructureMap) do zarządzania tworzeniem obiektu, ale nie mogę się domyślić, czy ten scenariusz jest możliwy. Wydaje się, że jest to cykl życia "warunkowego singletonu".

Czy StructureMap udostępnia taką funkcję? Jakieś alternatywne sugestie?

Answer 1

Prawdopodobnie użyłbym zakresu PerRequest i nie zwrócę bezpośrednio do IndexReader. Zamiast tego zwróciłabym abstrakcję z IndexReader, która wykonałaby sprawdzenie statycznego odniesienia na poziomie klasy.

Następnie, gdy twoja własność na shim/proxy/abstrakcji jest dostępna, to sprawdzi statyczny numer referencyjny (oczywiście sprawi, że będzie bezpieczny w wątkach) i ponownie pobierze numer IndexReader, zanim będzie dostarczony z powrotem do użytkownik.

Answer 2

W końcu poszedłem na prosty obiekt proxy, który otacza rzeczywisty IndexReader i zarządza ponowne otwarcie. Ponieważ potrzebuję użyć tego samego wystąpienia tego w poprzek żądań, używam StructureMap, aby zapewnić jego pojedynczą instancję. Kod poniżej.

Badałem tworzenie niestandardowego ILifecycle StructureMap, aby poradzić sobie z tą sytuacją, ale nie zaszły daleko, zobacz this question.

public class IndexReaderProxy 
{ 
    private IndexReader _indexReader; 
    private readonly object _indexReaderLock = new object(); 

    public IndexReaderProxy(Directory directory, bool readOnly) 
    { 
     _indexReader = IndexReader.Open(directory, readOnly); 
    } 

    public IndexReader GetCurrentIndexReader() 
    { 
     ReopenIndexReaderIfNotCurrent(); 
     return _indexReader; 
    } 

    private void ReopenIndexReaderIfNotCurrent() 
    { 
     if (_indexReader.IsCurrent()) return; 
     lock (_indexReaderLock) 
     { 
      if (_indexReader.IsCurrent()) return; 
      var newIndexReader = _indexReader.Reopen(); 
      _indexReader.Close(); 
      _indexReader = newIndexReader; 
     } 
    } 
} 

I rejestracja StructureMap:

For<IndexReaderProxy>().Singleton().Use(
      new IndexReaderProxy(FSDirectory.Open(new DirectoryInfo(LuceneIndexPath)), true) 
     );