addons/Thread/source/IoThread.c

   1 /*metadoc Thread copyright
   2         Steve Dekorte, 2006
   3 */
   4
   5 /*metadoc Thread license
   6         BSD revised
   7 */
   8
   9 /*metadoc Thread category
  10         Compression
  11 */
  12
  13 /*metadoc Thread description
  14         For native threads.
  15 Example use;
  16 <code>
  17 Thread createThread()
  18 </code>
  19 """)
  20 */
  21
  22 #include "IoThread.h"
  23 #include "IoState.h"
  24 #include "IoNumber.h"
  25 #include "IoSeq.h"
  26 #include <errno.h>
  27 #include "Thread.h"
  28 #include "List.h"
  29
  30 IoTag *IoThread_newTag(void *state)
  31 {
  32         IoTag *tag = IoTag_newWithName_("Thread");
  33         IoTag_state_(tag, state);
  34         IoTag_freeFunc_(tag, (IoTagFreeFunc *)IoThread_free);
  35         IoTag_cloneFunc_(tag, (IoTagCloneFunc *)IoThread_rawClone);
  36         return tag;
  37 }
  38
  39 IoThread *IoThread_proto(void *state)
  40 {
  41         IoThread *self = IoObject_new(state);
  42         IoObject_tag_(self, IoThread_newTag(state));
  43
  44         IoState_registerProtoWithFunc_(state, self, IoThread_proto);
  45
  46         {
  47                 IoMethodTable methodTable[] = {
  48                 {"threadCount", IoThread_threadCount},
  49                 {"createThread", IoThread_createThread},
  50                 //{"endCurrentThread", IoThread_endCurrentThread},
  51                 {NULL, NULL},
  52                 };
  53                 IoObject_addMethodTable_(self, methodTable);
  54         }
  55
  56         Thread_Init();
  57
  58         return self;
  59 }
  60
  61 IoThread *IoThread_rawClone(IoThread *proto)
  62 {
  63         IoObject *self = IoObject_rawClonePrimitive(proto);
  64         return self;
  65 }
  66
  67 IoThread *IoThread_new(void *state)
  68 {
  69         IoObject *proto = IoState_protoWithInitFunction_(state, IoThread_proto);
  70         return IOCLONE(proto);
  71 }
  72
  73 void IoThread_free(IoThread *self)
  74 {
  75 }
  76
  77 // --------------------------------------------
  78
  79 typedef struct
  80 {
  81         IoState *state;
  82         Thread *thread;
  83         char *evalString;
  84 } IoThreadInfo;
  85
  86 IoThreadInfo *IoThreadInfo_new(void)
  87 {
  88         IoThreadInfo *self = (IoThreadInfo *)calloc(1, sizeof(IoThreadInfo));
  89         return self;
  90 }
  91
  92 void IoThreadInfo_free(IoThreadInfo *self)
  93 {
  94         if(self->evalString) free(self->evalString);
  95         free(self);
  96 }
  97
  98 void IoThreadInfo_setState_(IoThreadInfo *self, IoState *state)
  99 {
 100         self->state = state;
 101 }
 102
 103 IoState *IoThreadInfo_state(IoThreadInfo *self)
 104 {
 105         return self->state;
 106 }
 107
 108 void IoThreadInfo_setThread_(IoThreadInfo *self, Thread *thread)
 109 {
 110         self->thread = thread;
 111 }
 112
 113 Thread *IoThreadInfo_thread(IoThreadInfo *self)
 114 {
 115         return self->thread;
 116 }
 117
 118 void IoThreadInfo_setEvalString_(IoThreadInfo *self, char *s)
 119 {
 120         self->evalString = strcpy(malloc(strlen(s) + 1), s);
 121 }
 122
 123 char *IoThreadInfo_evalString(IoThreadInfo *self)
 124 {
 125         return self->evalString;
 126 }
 127
 128 // ----------------------------------------------------
 129
 130 void *IoThread_BeginThread(void *vti)
 131 {
 132         IoThreadInfo *ti = (IoThreadInfo *)vti;
 133         Thread *t = IoThreadInfo_thread(ti);
 134         IoState *state = IoThreadInfo_state(ti);
 135
 136         Thread_setUserData_(t, state);
 137         IoState_doCString_(state, IoThreadInfo_evalString(ti));
 138         IoThreadInfo_free(ti);
 139         IoState_free(state);
 140         Thread_destroy(t);
 141         return NULL;
 142 }
 143
 144 IoObject *IoThread_createThread(IoObject *self, IoObject *locals, IoMessage *m)
 145 {
 146         IoSeq *s = IoMessage_locals_seqArgAt_(m, locals, 0);
 147         IoState *newState = IoState_new();
 148         Thread *t;
 149
 150         Thread_Init();
 151
 152         t = Thread_new();
 153
 154         IoThreadInfo *ti = IoThreadInfo_new();
 155         IoThreadInfo_setState_(ti, newState);
 156         IoThreadInfo_setThread_(ti, t);
 157         IoThreadInfo_setEvalString_(ti, CSTRING(s));
 158
 159         Thread_setFunc_(t, IoThread_BeginThread);
 160         Thread_setFuncArg_(t, (void *)ti);
 161         Thread_start(t);
 162
 163         return self;
 164 }
 165
 166 IoObject *IoThread_threadCount(IoObject *self, IoObject *locals, IoMessage *m)
 167 {
 168         Thread_Init();
 169         List *threads;
 170         size_t count;
 171
 172         threads = Thread_Threads();
 173         count = List_size(threads);
 174         List_free(threads);
 175
 176         return IONUMBER(count);
 177 }
 178
 179 IoObject *IoThread_endCurrentThread(IoObject *self, IoObject *locals, IoMessage *m)
 180 {
 181         // shutdown vm?
 182         Thread_destroy(Thread_CurrentThread());
 183         return self;
 184 }