include/ascii-chat/platform/thread.h

Go to the documentation of this file.

#pragma once
 
#include <stdbool.h>
#include <stdint.h>
 
// Type definitions MUST come before including common.h to avoid circular dependencies.
// common.h → abstraction.h → debug/lock.h → thread.h, and lock.h needs asciichat_thread_t.
#ifdef _WIN32
#include "windows_compat.h"
typedef HANDLE asciichat_thread_t;
typedef DWORD thread_id_t;
typedef DWORD tls_key_t;
#else
#include <pthread.h>
typedef pthread_t asciichat_thread_t;
typedef pthread_t thread_id_t;
typedef pthread_key_t tls_key_t;
#endif
 
#include "../common.h" // For asciichat_error_t (must come AFTER type definitions)
 
#ifdef __cplusplus
extern "C" {
#endif
 
// ============================================================================
// Thread-Local Storage Macros
// ============================================================================
 
#ifdef _WIN32
#define PLATFORM_THREAD_LOCAL __declspec(thread)
#else
#define PLATFORM_THREAD_LOCAL __thread
#endif
 
// ============================================================================
// Thread Lifecycle Management
// ============================================================================
 
typedef struct {
  void *(*user_func)(void *); // User's thread function
  void *user_arg;             // User's argument
} asciichat_thread_wrapper_t;
 
void *asciichat_thread_wrapper_impl(void *arg);
 
// ============================================================================
// Thread Functions
// ============================================================================
 
int asciichat_thread_create(asciichat_thread_t *thread, const char *name, void *(*func)(void *), void *arg);
 
int asciichat_thread_join(asciichat_thread_t *thread, void **retval);
 
int asciichat_thread_detach(asciichat_thread_t *thread);
 
int asciichat_thread_join_timeout(asciichat_thread_t *thread, void **retval, uint64_t timeout_ns);
 
void asciichat_thread_exit(void *retval);
 
thread_id_t asciichat_thread_self(void);
 
int asciichat_thread_equal(thread_id_t t1, thread_id_t t2);
 
uint64_t asciichat_thread_current_id(void);
 
bool asciichat_thread_is_initialized(asciichat_thread_t *thread);
 
void asciichat_thread_init(asciichat_thread_t *thread);
 
asciichat_error_t asciichat_thread_set_realtime_priority(void);
 
asciichat_error_t thread_create_or_fail(asciichat_thread_t *thread, void *(*func)(void *), void *arg,
                                        const char *thread_name, const char *client_id);
 
uintptr_t asciichat_thread_to_key(asciichat_thread_t thread);
 
// ============================================================================
// Thread-Local Storage (TLS) Functions
// ============================================================================
 
int ascii_tls_key_create(tls_key_t *key, void (*destructor)(void *));
 
int ascii_tls_key_delete(tls_key_t key);
 
void *ascii_tls_get(tls_key_t key);
 
int ascii_tls_set(tls_key_t key, void *value);
 
#ifdef __cplusplus
}
#endif