From 42d6d507961e45ebe09a08c758eb688d48869635 Mon Sep 17 00:00:00 2001
From: Przemyslaw Czerpak <druzus@priv.onet.pl>
Date: Thu, 9 Oct 2008 15:03:06 +0000
Subject: [PATCH] 2008-10-09 17:03 UTC+0200 Przemyslaw Czerpak
 (druzus/at/priv.onet.pl)   + harbour/source/rtl/thfuncx.prg     * added
 xbase++ compatible functions:          ThreadID() -> <nThId>         
 ThreadWait( <aThreads>, <nTimeOut> ) -> <oThread> | <pThId> | NIL         
 ThreadWaitAll( <aThreads>, <nTimeOut> ) -> <lAllFinished>       In Harbour
 <aThreads> can be array of thread pointers or thread       objects. xbase++
 compatible thread class I'll add later.

---
 harbour/ChangeLog              |  9 ++++
 harbour/source/rtl/thfuncx.prg | 98 ++++++++++++++++++++++++++++++++++
 2 files changed, 107 insertions(+)
 create mode 100644 harbour/source/rtl/thfuncx.prg

diff --git a/harbour/ChangeLog b/harbour/ChangeLog
index 9677c238e3..b65e9c6ee3 100644
--- a/harbour/ChangeLog
+++ b/harbour/ChangeLog
@@ -8,6 +8,15 @@
    2008-12-31 13:59 UTC+0100 Foo Bar (foo.bar foobar.org)
 */
 
+2008-10-09 17:03 UTC+0200 Przemyslaw Czerpak (druzus/at/priv.onet.pl)
+  + harbour/source/rtl/thfuncx.prg
+    * added xbase++ compatible functions:
+         ThreadID() -> <nThId>
+         ThreadWait( <aThreads>, <nTimeOut> ) -> <oThread> | <pThId> | NIL
+         ThreadWaitAll( <aThreads>, <nTimeOut> ) -> <lAllFinished>
+      In Harbour <aThreads> can be array of thread pointers or thread
+      objects. xbase++ compatible thread class I'll add later.
+
 2008-10-09 07:30 UTC-0500 Teo Fonrouge (teo/at/windtelsoft/dot/com)
   - bin/hb_flst.tmp
   * bin/pack_src.sh
diff --git a/harbour/source/rtl/thfuncx.prg b/harbour/source/rtl/thfuncx.prg
new file mode 100644
index 0000000000..6bd3d23748
--- /dev/null
+++ b/harbour/source/rtl/thfuncx.prg
@@ -0,0 +1,98 @@
+/*
+ * $Id$
+ */
+
+/*
+ * Harbour Project source code:
+ * XPP compatible thread functions
+ *
+ * Copyright 2008 Przemyslaw Czerpak <druzus / at / priv.onet.pl>
+ * www - http://www.harbour-project.org
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2, or (at your option)
+ * any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this software; see the file COPYING.  If not, write to
+ * the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
+ * Boston, MA 02111-1307 USA (or visit the web site http://www.gnu.org/).
+ *
+ * As a special exception, the Harbour Project gives permission for
+ * additional uses of the text contained in its release of Harbour.
+ *
+ * The exception is that, if you link the Harbour libraries with other
+ * files to produce an executable, this does not by itself cause the
+ * resulting executable to be covered by the GNU General Public License.
+ * Your use of that executable is in no way restricted on account of
+ * linking the Harbour library code into it.
+ *
+ * This exception does not however invalidate any other reasons why
+ * the executable file might be covered by the GNU General Public License.
+ *
+ * This exception applies only to the code released by the Harbour
+ * Project under the name Harbour.  If you copy code from other
+ * Harbour Project or Free Software Foundation releases into a copy of
+ * Harbour, as the General Public License permits, the exception does
+ * not apply to the code that you add in this way.  To avoid misleading
+ * anyone as to the status of such modified files, you must delete
+ * this exception notice from them.
+ *
+ * If you write modifications of your own for Harbour, it is your choice
+ * whether to permit this exception to apply to your modifications.
+ * If you do not wish that, delete this exception notice.
+ *
+ */
+
+#include "common.ch"
+
+#ifdef HB_COMPAT_XPP
+
+FUNCTION ThreadID()
+   RETURN hb_threadId()
+
+
+FUNCTION ThreadWait( aThreads, nTimeOut )
+   LOCAL xResult, nPos, apThIDs, th
+
+   apThIDs := {}
+   FOR each th IN aThreads
+      IF ISOBJECT( th )
+         AAdd( apThIDs, th:threadSelf )
+      ELSE
+         AAdd( apThIDs, th )
+      ENDIF
+   NEXT
+
+   nPos := hb_threadWait( apThIDs, iif( ISNUMBER( nTimeOut ), nTimeOut / 1000, ) )
+   IF nPos != 0
+      xResult := aThreads[ nPos ]
+   ENDIF
+
+   RETURN xResult
+
+
+FUNCTION ThreadWaitAll( aThreads, nTimeOut )
+   LOCAL apThIDs, th
+
+   apThIDs := {}
+   FOR each th IN aThreads
+      IF ISOBJECT( th )
+         AAdd( apThIDs, th:threadSelf )
+      ELSE
+         AAdd( apThIDs, th )
+      ENDIF
+   NEXT
+
+   RETURN hb_threadWait( apThIDs, iif( ISNUMBER( nTimeOut ), nTimeOut / 1000, ), ;
+                         .T. ) == Len( apThIDs )
+
+/* TODO: ThreadInfo() */
+
+#endif