a7072a5e1c
Before, the 'main thread' of a process was never taken into account anywhere in the library, causing mutexes not to work properly (and consequently, neither did the condition variables). For example, if the 'main thread' (that is, the thread which is started at the beginning of a process; not a spawned thread by the library) would lock a mutex, it wasn't actually locked.
47 lines
1.5 KiB
C
47 lines
1.5 KiB
C
/* EXTERN should be extern, except for the allocate file */
|
|
#ifdef ALLOCATE
|
|
#undef EXTERN
|
|
#define EXTERN
|
|
#endif
|
|
|
|
#include <assert.h>
|
|
|
|
#define NO_THREADS 4
|
|
#define MAX_THREAD_POOL 1024
|
|
#define STACKSZ 4096
|
|
#define MAIN_THREAD -1
|
|
#define NO_THREAD -2
|
|
#define isokthreadid(i) (i == MAIN_THREAD || (i >= 0 && i < no_threads))
|
|
|
|
typedef enum {
|
|
MS_CONDITION, MS_DEAD, MS_EXITING, MS_FALLBACK_EXITING, MS_MUTEX, MS_RUNNABLE
|
|
} mthread_state_t;
|
|
|
|
struct __mthread_tcb {
|
|
mthread_thread_t m_tid; /* My own ID */
|
|
mthread_state_t m_state; /* Thread state */
|
|
struct __mthread_attr m_attr; /* Thread attributes */
|
|
struct __mthread_cond *m_cond; /* Condition variable that this thread
|
|
* might be blocking on */
|
|
void *(*m_proc)(void *); /* Procedure to run */
|
|
void *m_arg; /* Argument passed to procedure */
|
|
void *m_result; /* Result after procedure returns */
|
|
mthread_cond_t m_exited; /* Condition variable signaling this
|
|
* thread has ended */
|
|
mthread_mutex_t m_exitm; /* Mutex to accompany exit condition */
|
|
ucontext_t m_context; /* Thread machine context */
|
|
struct __mthread_tcb *m_next; /* Next thread in linked list */
|
|
};
|
|
typedef struct __mthread_tcb mthread_tcb_t;
|
|
|
|
EXTERN mthread_thread_t current_thread;
|
|
EXTERN mthread_queue_t free_threads;
|
|
EXTERN mthread_queue_t run_queue; /* FIFO of runnable threads */
|
|
EXTERN mthread_tcb_t **threads;
|
|
EXTERN mthread_tcb_t fallback;
|
|
EXTERN mthread_tcb_t mainthread;
|
|
EXTERN int no_threads;
|
|
EXTERN int used_threads;
|
|
EXTERN int running_main_thread;
|
|
EXTERN char fallback_stack[STACKSZ];
|
|
|