thread.c

Go to the documentation of this file.

#include "thread.h"

#ifdef __cplusplus
extern "C" {
#endif

jobject getThreadObject(Thread* thread) {
   return thread->thread.thread;
}

void startThread(Thread* thread) {
   callVoidMethod(thread->thread.thread, thread->thread.mstart);
}

void setThreadPriority(Thread* thread, jint priority) {
   callVoidMethod(thread->thread.thread, thread->thread.msetPriority, priority);
}

jint getThreadPriority(Thread* thread) {
   return callIntMethod(thread->thread.thread, thread->thread.mgetPriority);
}

void sleepThread(Thread* thread, jlong milliseconds) {
   callVoidMethod(thread->thread.thread, thread->thread.msleep, milliseconds);
}

void yieldThread(Thread* thread) {
   callVoidMethod(thread->thread.thread, thread->thread.myield);
}

void cbThreadRun(JNIEnv *env, jobject jobj, jlong ptr) {
   void (*func)() = (void (*)())ptr;
   func();
}

void initThread_(Thread_* thread) {
   thread->getObject = &getThreadObject;
   thread->start = &startThread;
   thread->setPriority = &setThreadPriority;
   thread->getPriority = &getThreadPriority;
   thread->sleep = &sleepThread;
   thread->yield = &yieldThread;
}

void createThread_(Thread* thread, void (*func)()) {
   JNINativeMethod nm;

   thread->thread.clsthread = findClass(CLS_THREAD);
   thread->thread.mstart = findMethod(thread->thread.clsthread, "start", "()V");
   thread->thread.mgetPriority = findMethod(thread->thread.clsthread, "getPriority", "()I");
   thread->thread.msetPriority = findMethod(thread->thread.clsthread, "setPriority", "(I)V");
   thread->thread.msleep = findStaticMethod(thread->thread.clsthread, "sleep", "(J)V");
   thread->thread.myield = findStaticMethod(thread->thread.clsthread, "yield", "()V");

   nm.name = "cbThreadRun"; /* method name */
   nm.signature = "(J)V"; /* method signature */
   nm.fnPtr = (void*)&cbThreadRun; /* pointer of function to register */
   registerNatives(thread->thread.clsthread, &nm, 1);

   thread->thread.thread = newObjectBySignature(thread->thread.clsthread, "(J)V", func);
}

void createThreadCPP(ThreadCPP_* thread, void (*func)()) {
   thread->functions = (Thread_*)malloc(sizeof(Thread_));
   initThread_(thread->functions);
   createThread_((Thread*)thread, func);
}

void createThreadC(Thread_* thread, void (*func)()) {
   initThread_(thread);
   createThread_((Thread*)thread, func);
}

void deleteThread_(Thread* thread) {
   deleteGlobalReference(thread->thread.thread);
   deleteGlobalReference(thread->thread.clsthread);
}

void deleteThreadCPP(ThreadCPP_* thread) {
   deleteThread_((Thread*)thread);
   free(thread->functions);
}

void deleteThreadC(Thread_* thread) {
   deleteThread_((Thread*)thread);
}

#ifdef __cplusplus
} /* extern "C" */
#endif

/* end of file thread.c */

---