目錄
makefile
Thread.hpp
main.cc
以面向對象的方式造輪子
#ifndef _THREAD_HPP__ // 如果沒有定義過 _THREAD_HPP__
#define _THREAD_HPP__ // 則定義 _THREAD_HPP__// 這里是頭文件的實際內容（類、函數聲明等）#endif // 結束條件編譯
makefile
bin=testThread
cc=g++
src=$(wildcard *.cc)
obj=$(src:.cc=.o)$(bin):$(obj)$(cc) -o $@ $^ -lpthread
%.o:%.cc$(cc) -c $< -std=c++17.PHONY:clean
clean:rm -f $(bin) $(obj)Thread.hpp
#ifndef _THREAD_HPP__ // 如果沒有定義過 _THREAD_HPP__
#define _THREAD_HPP__ // 則定義 _THREAD_HPP__
#include<iostream>
#include<string>
#include<pthread.h>
#include<functional>
#include <sys/types.h>
#include <unistd.h>namespace ThreadModule
{
using func_t =std::function<void()>;
static int number = 1;
enum class STATUS
{NEW,RUNNING,STOP};class Thread
{// void* Route(void* args) 成員函數參數里有this指針 ,start(Route ,nullptr)編不過// {// }static void *Route(void* args) //static沒有傳進來this指針 ,也就不能使用成員變量 _name 等等{Thread* t =static_cast< Thread* >(args);t->_status =STATUS::RUNNING;t->_func();return nullptr;}void EnableDetach(){_joinable =false;}public:Thread(func_t func) :_func(func),_status(STATUS::NEW),_joinable(true){_name ="Thread-"+std::to_string(number++);_pid =getpid();}bool Start(){if(_status != STATUS::RUNNING)//防止重復啟動{int n =::pthread_create(&_tid ,nullptr, Route ,this );if(n !=0) return false;_status = STATUS::RUNNING;return true;}return false;}bool Stop(){if(_status == STATUS::RUNNING){int n= pthread_cancel(_tid);if(n!= 0) return false;_status = STATUS::STOP;return true;}return false;}void Detach(){EnableDetach();pthread_detach(_tid);}bool isjoinable(){return _joinable;}bool Join(){if( _joinable){int n =pthread_join(_tid ,nullptr);if(n != 0)return false;_status =STATUS::STOP;return true;}return false;}std::string Name(){return _name;}~Thread(){}
private:std::string _name;pthread_t _tid;pid_t _pid;STATUS _status; //線程結束(stop了)不代表Thread對象結束,因此應該設計線程狀態bool _joinable ;//是否分離 ,默認不是分離狀態, truefunc_t _func;
};} #endif // 結束條件編譯main.cc
#include"Thread.hpp"
#include<unordered_map>
#include<memory>#define NUM 10using thread_ptr_t = std::shared_ptr<ThreadModule::Thread>;//創建多線程
int main()
{// 先描述，在組織！std::unordered_map<std::string, thread_ptr_t> threads;// 如果我要創建多線程呢？？？for (int i = 0; i < NUM; i++){thread_ptr_t t = std::make_shared<ThreadModule::Thread>([](){while(true){std::cout << "hello world" << std::endl;sleep(1);}});threads[t->Name()] = t;}for(auto &thread:threads){thread.second->Start();}for(auto &thread:threads){thread.second->Join();}return 0;
}//創建線程
// int main()
// {
// ThreadModule::Thread t([](){// while(true)
// {
// std::cout<<"hello "<<std::endl;
// sleep(1);
// }
// });
// t.Start();
// std::cout<<t.Name()<<"is running"<<std::endl;// sleep(5);
// t.Stop();
// std::cout << "Stop thread : " << t.Name()<< std::endl;// sleep(1);
// t.Join();
// std::cout << "Join thread : " << t.Name()<< std::endl;// return 0;
// }
