os/thread.h

Go to the documentation of this file.

#pragma once
 
#include <libplatform/thread.h>
 
#if 0

 
/* Storage capacities in elements; text buffers include the terminating NUL. */
#define PLATFORM_THREAD_NAME_BUFFER_SIZE 128
 
#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 platform_thread_t.
#ifdef _WIN32
#include "windows_compat.h"
typedef HANDLE platform_thread_t;
typedef DWORD thread_id_t;
typedef DWORD tls_key_t;
#else
#include <pthread.h>
typedef pthread_t platform_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
  char name[PLATFORM_THREAD_NAME_BUFFER_SIZE]; // Owned name available before the first worker log
} asciichat_thread_wrapper_t;

void *thread_wrapper_impl(void *arg);
 
// ============================================================================
// Thread Functions
// ============================================================================

int platform_thread_create(platform_thread_t *thread, const char *name, void *(*func)(void *), void *arg);

int thread_join(platform_thread_t *thread, void **retval);

int thread_detach(platform_thread_t *thread);

int thread_join_timeout(platform_thread_t *thread, void **retval, uint64_t timeout_ns);

void thread_exit(void *retval);

thread_id_t thread_self(void);

int thread_equal(thread_id_t t1, thread_id_t t2);

uint64_t thread_current_id(void);

bool thread_is_initialized(platform_thread_t *thread);

void thread_init(platform_thread_t *thread);

asciichat_error_t thread_set_realtime_priority(void);

asciichat_error_t thread_create_or_fail(platform_thread_t *thread, void *(*func)(void *), void *arg,
                                        const char *thread_name, const char *client_id);

uintptr_t thread_to_key(platform_thread_t thread);
 
// ============================================================================
// Thread-Local Storage (TLS) Functions
// ============================================================================

int platform_tls_key_create(tls_key_t *key, void (*destructor)(void *));

int platform_tls_key_delete(tls_key_t key);

void *platform_tls_get(tls_key_t key);

int platform_tls_set(tls_key_t key, void *value);
 
#ifdef __cplusplus
}
#endif

#endif