test_thread.c

#include <string.h>
#include <stdio.h>
#include <LCUI_Build.h>
#include <LCUI/LCUI.h>
#include <LCUI/thread.h>
#include <LCUI/util/logger.h>
#include "test.h"
#include "libtest.h"

typedef struct TestWorkerRec_ {
	char data[32];
	int data_count;
	LCUI_BOOL cancel;
	LCUI_BOOL active;
	LCUI_Cond cond;
	LCUI_Mutex mutex;
	LCUI_Thread thread;
} TestWorkerRec, *TestWorker;

static void TestWorker_Thread(void *arg)
{
	TestWorker worker = arg;

	worker->cancel = FALSE;
	worker->active = TRUE;
	worker->data_count = 0;
	LCUIMutex_Lock(&worker->mutex);
	while (!worker->cancel && worker->data_count < 20) {
		Logger_Debug("waiting...\n");
		LCUICond_Wait(&worker->cond, &worker->mutex);
		Logger_Debug("get data: %s\n", worker->data);
		worker->data_count += 1;
	}
	LCUIMutex_Unlock(&worker->mutex);
	Logger_Debug("count: %d\n", worker->data_count);
	worker->active = FALSE;
	LCUIThread_Exit(NULL);
}

static void TestWorker_Send(TestWorker worker, const char *data)
{
	LCUIMutex_Lock(&worker->mutex);
	strcpy(worker->data, data);
	LCUICond_Signal(&worker->cond);
	LCUIMutex_Unlock(&worker->mutex);
}

static void TestWorker_Init(TestWorker worker)
{
	LCUIMutex_Init(&worker->mutex);
	LCUICond_Init(&worker->cond);
}

static void TestWorker_Destroy(TestWorker worker)
{
	LCUIMutex_Lock(&worker->mutex);
	worker->cancel = TRUE;
	LCUICond_Signal(&worker->cond);
	LCUIMutex_Unlock(&worker->mutex);
	LCUIThread_Join(worker->thread, NULL);
	LCUIMutex_Destroy(&worker->mutex);
	LCUICond_Destroy(&worker->cond);
}

void test_thread(void)
{
	TestWorkerRec worker;

	TestWorker_Init(&worker);
	LCUIThread_Create(&worker.thread, TestWorker_Thread, &worker);
	LCUI_MSleep(100);
	TestWorker_Send(&worker, "hello");
	LCUI_MSleep(20);
	TestWorker_Send(&worker, "world");
	LCUI_MSleep(100);
	TestWorker_Send(&worker, "this");
	LCUI_MSleep(50);
	TestWorker_Send(&worker, "is");
	LCUI_MSleep(100);
	TestWorker_Send(&worker, "test");
	LCUI_MSleep(50);
	TestWorker_Send(&worker, "bye!");
	LCUI_MSleep(100);
	TestWorker_Destroy(&worker);
	it_i("check worker data count", worker.data_count, 7);
	it_b("check worker is no longer active", worker.active, FALSE);
}