define stacksize for new threads

Author: aldrik-ramaekers

include/allegro5/internal/aintern_thread.h

@@ -14,6 +14,7 @@ typedef struct _AL_COND _AL_COND;
 
 
 void _al_thread_create(_AL_THREAD*, void (*proc)(_AL_THREAD*, void*), void *arg);
+void _al_thread_with_stacksize_create(_AL_THREAD*, void (*proc)(_AL_THREAD*, void*), void *arg, size_t stacksize);
 void _al_thread_set_should_stop(_AL_THREAD *);
 /* static inline bool _al_get_thread_should_stop(_AL_THREAD *); */
 void _al_thread_join(_AL_THREAD*);

include/allegro5/threads.h

@@ -37,6 +37,8 @@ typedef struct ALLEGRO_COND ALLEGRO_COND;
 
 AL_FUNC(ALLEGRO_THREAD *, al_create_thread,
    (void *(*proc)(ALLEGRO_THREAD *thread, void *arg), void *arg));
+AL_FUNC(ALLEGRO_THREAD *, al_create_thread_with_stacksize,
+   (void *(*proc)(ALLEGRO_THREAD *thread, void *arg), void *arg, size_t stacksize));
 AL_FUNC(void, al_start_thread, (ALLEGRO_THREAD *outer));
 AL_FUNC(void, al_join_thread, (ALLEGRO_THREAD *outer, void **ret_value));
 AL_FUNC(void, al_set_thread_should_stop, (ALLEGRO_THREAD *outer));

src/threads.c

@@ -126,7 +126,21 @@ ALLEGRO_THREAD *al_create_thread(
    return outer;
 }
 
-
+/* Function: al_create_thread_with_stacksize
+ */
+ALLEGRO_THREAD *al_create_thread_with_stacksize(
+void *(*proc)(ALLEGRO_THREAD *thread, void *arg), void *arg, size_t stacksize)
+{
+    ALLEGRO_THREAD *outer = create_thread();
+    outer->thread_state = THREAD_STATE_CREATED;
+    _al_mutex_init(&outer->mutex);
+    _al_cond_init(&outer->cond);
+    outer->arg = arg;
+    outer->proc = proc;
+    _al_thread_with_stacksize_create(&outer->thread, thread_func_trampoline, outer, stacksize);
+    /* XXX _al_thread_create should return an error code */
+    return outer;
+}
 
 /* Function: al_run_detached_thread
  */

src/unix/uxthread.c

@@ -70,6 +70,34 @@ void _al_thread_create(_AL_THREAD *thread, void (*proc)(_AL_THREAD*, void*), voi
 }
 
 
+void _al_thread_with_stacksize_create(_AL_THREAD* thread, void (*proc)(_AL_THREAD*, void*), void *arg, size_t stacksize) 
+{
+    ASSERT(thread);
+    ASSERT(proc);
+    {
+        int status;
+
+        pthread_mutex_init(&thread->mutex, NULL);
+
+        thread->should_stop = false;
+        thread->proc = proc;
+        thread->arg = arg;
+
+        // stacksize should be PTHREAD_STACK_MIN or more (16kb?)
+        pthread_attr_t thread_attr;
+        int s = 0;
+        s = pthread_attr_init(&thread_attr);
+        ASSERT(s==0);
+        s = pthread_attr_setstacksize(&thread_attr, stacksize);
+
+        status = pthread_create(&thread->thread, &thread_attr, thread_proc_trampoline, thread);
+        ASSERT(status == 0);
+        if (status != 0)
+            abort();
+    }
+}
+
+
 void _al_thread_set_should_stop(_AL_THREAD *thread)
 {
    ASSERT(thread);

src/win/wxthread.c

@@ -57,6 +57,23 @@ void _al_thread_create(_AL_THREAD *thread, void (*proc)(_AL_THREAD*, void*), voi
 }
 
 
+void _al_thread_with_stacksize_create(_AL_THREAD* thread, void (*proc)(_AL_THREAD*, void*), void *arg, size_t stacksize) 
+{
+    ASSERT(thread);
+    ASSERT(proc);
+    {
+        InitializeCriticalSection(&thread->cs);
+		
+        thread->should_stop = false;
+        thread->proc = proc;
+        thread->arg = arg;
+		
+        thread->thread = (void *)_beginthreadex(NULL, stacksize,
+                                                thread_proc_trampoline, thread, 0, NULL);
+    }
+}
+
+
 void _al_thread_set_should_stop(_AL_THREAD *thread)
 {
    ASSERT(thread);