ICU-57131.0.1.tar.gz

[apple/icu.git] / icuSources / test / intltest / simplethread.h

diff --git a/icuSources/test/intltest/simplethread.h b/icuSources/test/intltest/simplethread.h
index 9cd0fc2f7e1564c9cc7974cebf73ade35cbe2402..0580b72d4af2a445a4572c0c590f7472ba6b33c7 100644 (file)
--- a/icuSources/test/intltest/simplethread.h
+++ b/icuSources/test/intltest/simplethread.h
@@ -1,6 +1,6 @@
 /********************************************************************
  * COPYRIGHT: 
- * Copyright (c) 1997-2009, International Business Machines Corporation and
+ * Copyright (c) 1997-2015, International Business Machines Corporation and
  * others. All Rights Reserved.
  ********************************************************************/
 
@@ -11,21 +11,67 @@
 
 class U_EXPORT SimpleThread
 {
-public:
+  public:
     SimpleThread();
     virtual  ~SimpleThread();
-    int32_t   start(void);        // start the thread
-    UBool     isRunning();        // return true if a started thread has exited.
+    int32_t   start(void);        // start the thread. Return 0 if successfull.
+    void      join();             // A thread must be joined before deleting its SimpleThread.
 
     virtual void run(void) = 0;   // Override this to provide the code to run
                                   //   in the thread.
+  private:
     void *fImplementation;
+};
+
+
+class IntlTest;
+
+// ThreadPool - utililty class to simplify the spawning a group of threads by
+//              a multi-threaded test.
+//
+//   Usage: from within an intltest test function,
+//       ThreadPool<TestClass> pool(
+//               this,              // The current intltest test object,
+//                                  //     of type "TestClass *"
+//               numberOfThreads,   // How many threads to spawn.
+//               &TestClass::func); // The function to be run by each thread.
+//                                  //     It takes one int32_t parameter which
+//                                  //     is set to the thread number, 0 to numberOfThreads-1.
+//
+//       pool.start();              // Start all threads running.
+//       pool.join();               // Wait until all threads have terminated.
 
-public:
-    static void sleep(int32_t millis); // probably shouldn't go here but oh well.
-    static void errorFunc();      // Empty function, provides a single convenient place
-                                  //   to break on errors.
+class ThreadPoolBase {
+  public:
+    ThreadPoolBase(IntlTest *test, int32_t numThreads);
+    virtual ~ThreadPoolBase();
+    
+    void start();
+    void join();
+
+  protected:
+    virtual void callFn(int32_t param) = 0;
+    friend class ThreadPoolThread;
+
+    IntlTest  *fIntlTest;
+    int32_t  fNumThreads;
+    SimpleThread **fThreads;
 };
 
+
+template<class TestClass>
+class ThreadPool : public ThreadPoolBase {
+  private:
+    void (TestClass::*fRunFnPtr)(int32_t);
+  public:
+    ThreadPool(TestClass *test, int howMany, void (TestClass::*runFnPtr)(int32_t threadNumber)) :
+        ThreadPoolBase(test, howMany), fRunFnPtr(runFnPtr) {};
+    virtual ~ThreadPool() {};
+  private:
+    virtual void callFn(int32_t param) {
+        TestClass *test = dynamic_cast<TestClass *>(fIntlTest);
+        (test->*fRunFnPtr)(param);
+    }
+};
 #endif