-
Notifications
You must be signed in to change notification settings - Fork 0
/
Thread.cpp
64 lines (58 loc) · 1.11 KB
/
Thread.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
//=====================================================================
//
// Thread.cpp -
//
// Created by wwq on 2022/08/21
// Last Modified: 2022/08/21 15:35:57
//
//=====================================================================
#include "Thread.h"
#include "CurrentThread.h"
#include <cstdio>
#include <memory>
#include <semaphore.h>
using namespace simple_muduo;
std::atomic_int Thread::numCreated_(0);
Thread::Thread(ThreadFunc func, const std::string name)
: started_(false)
, joined_(false)
, tid_(0)
, func_(std::move(func))
, name_(name)
{
setDefaultName();
}
Thread::~Thread()
{
if(started_ && !joined_)
{
thread_->detach();
}
}
void Thread::start()
{
started_ = true;
sem_t sem;
sem_init(&sem, false, 0);
thread_ = std::shared_ptr<std::thread>(new std::thread([&](){
tid_ = CurrentThread::tid();
sem_post(&sem);
func_();
}));
sem_wait(&sem);
}
void Thread::join()
{
joined_ = true;
thread_->join();
}
void Thread::setDefaultName()
{
int num = ++numCreated_;
if(name_.empty())
{
char buf[32] = {0};
snprintf(buf, sizeof(buf), "Thread%d", num);
name_ = buf;
}
}