thread.h 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. #ifndef __THREAD_Hx__
  2. #define __THREAD_Hx__
  3. #include <pthread.h>
  4. #include <stdio.h>
  5. #ifdef __cplusplus
  6. extern "C" {
  7. #endif
  8. #define KB 1024
  9. #define MB (KB*KB)
  10. enum {
  11. THREAD_ID_WS=0,
  12. THREAD_ID_WEB,
  13. THREAD_ID_SNMP,
  14. THREAD_ID_POWER,
  15. THREAD_ID_POLL,
  16. THREAD_ID_MQTT,
  17. THREAD_ID_MAIL,
  18. THREAD_ID_MAX
  19. };
  20. typedef void *(*thread_fn)(void *arg);
  21. typedef struct {
  22. const char *name;
  23. thread_fn fn;
  24. void *arg;
  25. int stksz;
  26. int prio;
  27. }thread_attr_t;
  28. typedef struct {
  29. const char *name;
  30. pthread_t tid;
  31. int quit;
  32. int running;
  33. void *arg;
  34. thread_fn fn;
  35. void *stk;
  36. }thread_handle_t;
  37. int thread_start(int id, thread_fn fn, void *arg);
  38. int thread_start2(int id);
  39. int thread_restart(int id);
  40. int thread_startEx(int id, const char *name, thread_fn fn, void *arg, int stksz, int prio);
  41. int thread_stop(int id);
  42. int thread_stop_all(void);
  43. int thread_is_running(int id);
  44. int thread_start_simp(thread_fn fn, void *arg, int stksz);
  45. int thread_print_stacksize(void);
  46. #ifdef __cplusplus
  47. }
  48. #endif
  49. #endif