1

Hibernate Searchの同期実行では、呼び出しスレッド以外のスレッドを使用して並列実行しているようです。

呼び出し元のスレッドでHibernateSearchの実行を連続して実行するにはどうすればよいですか？

問題はorg.hibernate.search.backend.impl.lucene.QueueProcessorsクラスにあるようです： 

private void runAllWaiting() throws InterruptedException {
        List<Future<Object>> futures = new ArrayList<Future<Object>>( dpProcessors.size() );
        // execute all work in parallel on each DirectoryProvider;
        // each DP has it's own ExecutorService.
        for ( PerDPQueueProcessor process : dpProcessors.values() ) {
            ExecutorService executor = process.getOwningExecutor();
            //wrap each Runnable in a Future
            FutureTask<Object> f = new FutureTask<Object>( process, null );
            futures.add( f );
            executor.execute( f );
        }
        // and then wait for all tasks to be finished:
        for ( Future<Object> f : futures ) {
            if ( !f.isDone() ) {
                try {
                    f.get();
                }
                catch (CancellationException ignore) {
                    // ignored, as in java.util.concurrent.AbstractExecutorService.invokeAll(Collection<Callable<T>>
                    // tasks)
                }
                catch (ExecutionException error) {
                    // rethrow cause to serviced thread - this could hide more exception:
                    Throwable cause = error.getCause();
                    throw new SearchException( cause );
                }
            }
        }
    }

シリアル同期実行は呼び出し元のスレッドで発生し、認証情報などのコンテキスト情報を基になるDirectoryProviderに公開します。

4

1 に答える 1

1

非常に古い質問ですが、私はそれに答えたほうがいいかもしれません...

IndexWriterHibernate Searchは、ディレクトリ（Luceneで必要）のLuceneへのシングルスレッドアクセスを保証するためにこれを行います。ディレクトリごとにシングルスレッドのエグゼキュータを使用することが、キューイングの問題に対処する方法だったと思います。

すべてを呼び出し元のスレッドで実行する場合は、を再実装して、休止状態のプロパティにLuceneBackendQueueProcessorFactoryバインドする必要があります。hibernate.search.worker.backend些細なことではありませんが、実行可能です。

于 2012-02-19T14:26:26.117 に答える