1 files changed, 95 insertions, 0 deletions
diff --git a/ACE/ace/Thread.cpp b/ACE/ace/Thread.cpp
new file mode 100644
index 00000000000..a920e131be9
--- /dev/null
+++ b/ACE/ace/Thread.cpp
@@ -0,0 +1,95 @@
+// $Id$
+
+#include "ace/Thread.h"
+
+ACE_RCSID(ace,
+          Thread,
+          "$Id$")
+
+#if !defined (__ACE_INLINE__)
+#include "ace/Thread.inl"
+#endif /* !defined (__ACE_INLINE__) */
+
+#if defined (ACE_HAS_THREADS)
+
+ACE_BEGIN_VERSIONED_NAMESPACE_DECL
+
+size_t
+ACE_Thread::spawn_n (size_t n,
+                     ACE_THR_FUNC func,
+                     void *arg,
+                     long flags,
+                     long priority,
+                     void *stack[],
+                     size_t stack_size[],
+                     ACE_Thread_Adapter *thread_adapter)
+{
+  ACE_TRACE ("ACE_Thread::spawn_n");
+  ACE_thread_t t_id;
+  size_t i;
+
+  for (i = 0; i < n; i++)
+    // Bail out if error occurs.
+    if (ACE_OS::thr_create (func,
+                            arg,
+                            flags,
+                            &t_id,
+                            0,
+                            priority,
+                            stack == 0 ? 0 : stack[i],
+                            stack_size == 0 ? 0 : stack_size[i],
+                            thread_adapter) != 0)
+      break;
+
+  return i;
+}
+
+size_t
+ACE_Thread::spawn_n (ACE_thread_t thread_ids[],
+                     size_t n,
+                     ACE_THR_FUNC func,
+                     void *arg,
+                     long flags,
+                     long priority,
+                     void *stack[],
+                     size_t stack_size[],
+                     ACE_hthread_t thread_handles[],
+                     ACE_Thread_Adapter *thread_adapter)
+{
+  ACE_TRACE ("ACE_Thread::spawn_n");
+  size_t i;
+
+  for (i = 0; i < n; i++)
+    {
+      ACE_thread_t t_id;
+      ACE_hthread_t t_handle;
+
+      int result =
+        ACE_OS::thr_create (func,
+                            arg,
+                            flags,
+                            &t_id,
+                            &t_handle,
+                            priority,
+                            stack == 0 ? 0 : stack[i],
+                            stack_size == 0 ? 0 : stack_size[i],
+                            thread_adapter);
+
+      if (result == 0)
+        {
+          if (thread_ids != 0)
+            thread_ids[i] = t_id;
+          if (thread_handles != 0)
+            thread_handles[i] = t_handle;
+        }
+      else
+        // Bail out if error occurs.
+        break;
+    }
+
+  return i;
+}
+
+ACE_END_VERSIONED_NAMESPACE_DECL
+
+#endif /* ACE_HAS_THREADS */