ddnet/src/test/thread.cpp

84 lines
1.4 KiB
C++
Raw Normal View History

2017-10-09 22:08:24 +00:00
#include <gtest/gtest.h>
#include <base/system.h>
static void Nothing(void *pUser)
{
(void)pUser;
}
TEST(Thread, Detach)
{
void *pThread = thread_init(Nothing, 0, "detach");
2017-10-09 22:08:24 +00:00
thread_detach(pThread);
}
static void SetToOne(void *pUser)
{
*(int *)pUser = 1;
}
TEST(Thread, Wait)
{
int Integer = 0;
void *pThread = thread_init(SetToOne, &Integer, "wait");
2017-10-09 22:08:24 +00:00
thread_wait(pThread);
EXPECT_EQ(Integer, 1);
}
TEST(Thread, Yield)
{
thread_yield();
}
TEST(Thread, Semaphore)
{
SEMAPHORE Semaphore;
sphore_init(&Semaphore);
sphore_destroy(&Semaphore);
}
TEST(Thread, SemaphoreSingleThreaded)
{
SEMAPHORE Semaphore;
sphore_init(&Semaphore);
sphore_signal(&Semaphore);
sphore_signal(&Semaphore);
sphore_wait(&Semaphore);
sphore_wait(&Semaphore);
sphore_destroy(&Semaphore);
}
static void SemaphoreThread(void *pUser)
{
SEMAPHORE *pSemaphore = (SEMAPHORE *)pUser;
sphore_wait(pSemaphore);
}
TEST(Thread, SemaphoreMultiThreaded)
{
SEMAPHORE Semaphore;
sphore_init(&Semaphore);
sphore_signal(&Semaphore);
void *pThread = thread_init(SemaphoreThread, &Semaphore, "semaphore");
2017-10-09 22:08:24 +00:00
thread_wait(pThread);
sphore_destroy(&Semaphore);
}
static void LockThread(void *pUser)
{
LOCK *pLock = (LOCK *)pUser;
lock_wait(*pLock);
lock_unlock(*pLock);
}
TEST(Thread, Lock)
{
LOCK Lock = lock_create();
lock_wait(Lock);
void *pThread = thread_init(LockThread, &Lock, "lock");
2017-10-09 22:08:24 +00:00
lock_unlock(Lock);
thread_wait(pThread);
lock_destroy(Lock);
2017-10-09 22:08:24 +00:00
}