Move thread-pool down into comphelper for re-use elsewhere.

Change-Id: Ib27b8b1ccc07ff194035d6c2ef3d45c429e3cea1

3 files changed, 3 insertions, 220 deletions

diff --git a/sc/source/filter/oox/threadpool.cxx b/sc/source/filter/oox/threadpool.cxx
deleted file mode 100644
index 3fcfa755129c..000000000000
--- a/sc/source/filter/oox/threadpool.cxx
+++ /dev/null
@@ -1,164 +0,0 @@
-/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
-/*
- * This file is part of the LibreOffice project.
- *
- * This Source Code Form is subject to the terms of the Mozilla Public
- * License, v. 2.0. If a copy of the MPL was not distributed with this
- * file, You can obtain one at http://mozilla.org/MPL/2.0/.
- */
-
-#include "threadpool.hxx"
-
-#include <algorithm>
-
-class ThreadPool::ThreadWorker : public salhelper::Thread
-{
-    ThreadPool    *mpPool;
-    osl::Condition maNewWork;
-public:
-    ThreadWorker( ThreadPool *pPool ) :
-        salhelper::Thread("sheet-import-thread-pool"),
-        mpPool( pPool ) {}
-
-    virtual void execute() SAL_OVERRIDE
-    {
-        ThreadTask *pTask;
-        while ( ( pTask = waitForWork() ) )
-        {
-            pTask->doWork();
-            delete pTask;
-        }
-    }
-
-    ThreadTask *waitForWork()
-    {
-        ThreadTask *pRet = NULL;
-
-        osl::ResettableMutexGuard aGuard( mpPool->maGuard );
-
-        pRet = mpPool->popWork();
-
-        while( !pRet )
-        {
-            maNewWork.reset();
-
-            if( mpPool->mbTerminate )
-                break;
-
-            aGuard.clear(); // unlock
-
-            maNewWork.wait();
-
-            aGuard.reset(); // lock
-
-            pRet = mpPool->popWork();
-        }
-
-        return pRet;
-    }
-
-    // Why a condition per worker thread - you may ask.
-    //
-    // Unfortunately the Windows synchronisation API that we wrap
-    // is horribly inadequate cf.
-    //    http://www.cs.wustl.edu/~schmidt/win32-cv-1.html
-    // The existing osl::Condition API should only ever be used
-    // between one producer and one consumer thread to avoid the
-    // lost wakeup problem.
-
-    void signalNewWork()
-    {
-        maNewWork.set();
-    }
-};
-
-ThreadPool::ThreadPool( sal_Int32 nWorkers ) :
-    mbTerminate( false )
-{
-    for( sal_Int32 i = 0; i < nWorkers; i++ )
-        maWorkers.push_back( new ThreadWorker( this ) );
-
-    maTasksEmpty.reset();
-
-    osl::MutexGuard aGuard( maGuard );
-    for( size_t i = 0; i < maWorkers.size(); i++ )
-        maWorkers[ i ]->launch();
-}
-
-ThreadPool::~ThreadPool()
-{
-    waitUntilWorkersDone();
-}
-
-/// wait until all the workers have completed and
-/// terminate all threads
-void ThreadPool::waitUntilWorkersDone()
-{
-    waitUntilEmpty();
-
-    osl::ResettableMutexGuard aGuard( maGuard );
-    mbTerminate = true;
-
-    while( !maWorkers.empty() )
-    {
-        rtl::Reference< ThreadWorker > xWorker = maWorkers.back();
-        maWorkers.pop_back();
-        assert(std::find(maWorkers.begin(), maWorkers.end(), xWorker)
-                == maWorkers.end());
-        xWorker->signalNewWork();
-        aGuard.clear();
-        { // unlocked
-            xWorker->join();
-            xWorker.clear();
-        }
-        aGuard.reset();
-    }
-}
-
-void ThreadPool::pushTask( ThreadTask *pTask )
-{
-    osl::MutexGuard aGuard( maGuard );
-    maTasks.insert( maTasks.begin(), pTask );
-    // horrible beyond belief:
-    for( size_t i = 0; i < maWorkers.size(); i++ )
-        maWorkers[ i ]->signalNewWork();
-    maTasksEmpty.reset();
-}
-
-ThreadTask *ThreadPool::popWork()
-{
-    if( !maTasks.empty() )
-    {
-        ThreadTask *pTask = maTasks.back();
-        maTasks.pop_back();
-        return pTask;
-    }
-    else
-        maTasksEmpty.set();
-    return NULL;
-}
-
-void ThreadPool::waitUntilEmpty()
-{
-    osl::ResettableMutexGuard aGuard( maGuard );
-
-    if( maWorkers.empty() )
-    { // no threads at all -> execute the work in-line
-        ThreadTask *pTask;
-        while ( ( pTask = popWork() ) )
-        {
-            pTask->doWork();
-            delete pTask;
-        }
-        mbTerminate = true;
-    }
-    else
-    {
-        aGuard.clear();
-        maTasksEmpty.wait();
-        aGuard.reset();
-    }
-    assert( maTasks.empty() );
-}
-
-/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
diff --git a/sc/source/filter/oox/threadpool.hxx b/sc/source/filter/oox/threadpool.hxx
deleted file mode 100644
index 19b524c57d4e..000000000000
--- a/sc/source/filter/oox/threadpool.hxx
+++ /dev/null
@@ -1,53 +0,0 @@
-/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
-/*
- * This file is part of the LibreOffice project.
- *
- * This Source Code Form is subject to the terms of the Mozilla Public
- * License, v. 2.0. If a copy of the MPL was not distributed with this
- * file, You can obtain one at http://mozilla.org/MPL/2.0/.
- */
-
-#ifndef INCLUDED_SC_SOURCE_FILTER_OOX_THREADPOOL_HXX
-#define INCLUDED_SC_SOURCE_FILTER_OOX_THREADPOOL_HXX
-
-#include <sal/config.h>
-#include <salhelper/thread.hxx>
-#include <osl/mutex.hxx>
-#include <osl/conditn.hxx>
-#include <rtl/ref.hxx>
-#include <vector>
-
-class ThreadTask
-{
-public:
-    virtual      ~ThreadTask() {}
-    virtual void doWork() = 0;
-};
-
-/// A very basic thread pool implementation
-class ThreadPool
-{
-public:
-                ThreadPool( sal_Int32 nWorkers );
-    virtual    ~ThreadPool();
-    void        pushTask( ThreadTask *pTask /* takes ownership */ );
-    void        waitUntilEmpty();
-    void        waitUntilWorkersDone();
-
-private:
-    class ThreadWorker;
-    friend class ThreadWorker;
-
-    ThreadTask *waitForWork( osl::Condition &rNewWork );
-    ThreadTask *popWork();
-
-    osl::Mutex maGuard;
-    osl::Condition maTasksEmpty;
-    bool mbTerminate;
-    std::vector< rtl::Reference< ThreadWorker > > maWorkers;
-    std::vector< ThreadTask * >   maTasks;
-};
-
-#endif // INCLUDED_SC_SOURCE_FILTER_OOX_THREADPOOL_HXX
-
-/* vim:set shiftwidth=4 softtabstop=4 expandtab: */
diff --git a/sc/source/filter/oox/workbookfragment.cxx b/sc/source/filter/oox/workbookfragment.cxx
index 26bf3b48e06b..62ea5bb415e1 100644
--- a/sc/source/filter/oox/workbookfragment.cxx
+++ b/sc/source/filter/oox/workbookfragment.cxx
@@ -46,7 +46,6 @@
 #include "worksheethelper.hxx"
 #include "worksheetfragment.hxx"
 #include "sheetdatacontext.hxx"
-#include "threadpool.hxx"
 #include "officecfg/Office/Common.hxx"
 
 #include "document.hxx"
@@ -58,6 +57,7 @@
 
 #include <oox/core/fastparser.hxx>
 #include <salhelper/thread.hxx>
+#include <comphelper/threadpool.hxx>
 #include <osl/conditn.hxx>
 
 #include <algorithm>
@@ -207,7 +207,7 @@ namespace {
 typedef std::pair<WorksheetGlobalsRef, FragmentHandlerRef> SheetFragmentHandler;
 typedef std::vector<SheetFragmentHandler> SheetFragmentVector;
 
-class WorkerThread : public ThreadTask
+class WorkerThread : public comphelper::ThreadTask
 {
     sal_Int32 &mrSheetsLeft;
     WorkbookFragment& mrWorkbookHandler;
@@ -311,7 +311,7 @@ void importSheetFragments( WorkbookFragment& rWorkbookHandler, SheetFragmentVect
         // test sequential read in this mode
         if( nThreads < 0)
             nThreads = 0;
-        ThreadPool aPool( nThreads );
+        comphelper::ThreadPool aPool( nThreads );
 
         sal_Int32 nSheetsLeft = 0;
         ProgressBarTimer aProgressUpdater;