C++：pthread线程分离和线程属性 - ToB企服应用市场:ToB评测及商务社交产业平台

int pthread_detach(pthread_t thread);

复制代码

#include <iostream>
#include <pthread.h>
#include <unistd.h>
// 线程函数
void* thread_function(void* arg) {
sleep(2);
std::cout << "This is a detached thread." << std::endl;
return nullptr;
}
int main() {
pthread_t thread;
// 创建线程
if (pthread_create(&thread, nullptr, thread_function, nullptr)!= 0) {
std::cerr << "Failed to create thread" << std::endl;
return 1;
}
// 将线程设置为分离状态
if (pthread_detach(thread)!= 0) {
std::cerr << "Failed to detach thread" << std::endl;
return 1;
}
std::cout << "Detached thread created successfully." << std::endl;
// 主线程继续执行其他任务
sleep(3);
return 0;
}

复制代码

#include <iostream>
#include <pthread.h>
#include <unistd.h>
using namespace std;
int j = 2;
void* pthread_fun(void *arg)
{
//自己设置为detached状态
int ret = pthread_detach(pthread_self());
while(j--)
{
cout << " in pthread_task" << endl;
cout << *(int*)arg << endl;
sleep(1);
}
// 线程返回一个整数值
int* result = new int(42);
return static_cast<void*>(result);//pthread_exit(reinterpret_cast<void*>(result));
}
int main()
{
int ret = 0;
pthread_t tid = 0;
int argsend = 99;
int i = 3;
ret = pthread_create(&tid, NULL, pthread_fun, &argsend);
if(ret != 0)
{
cout << " pthread_create error" << endl;
return -1;
}
while(i--)
{
cout << "pthread _create success" << endl;
sleep(2);
}
return 0;
}

复制代码

pthread_attr_t attr;
pthread_attr_init(&attr);
size_t stack_size = 1024 * 1024; // 1MB栈大小
pthread_attr_setstacksize(&attr, stack_size);

复制代码

pthread_attr_t attr;
pthread_attr_init(&attr);
pthread_attr_setschedpolicy(&attr, SCHED_RR);

复制代码

pthread_attr_t attr;
pthread_attr_init(&attr);
struct sched_param param;
param.sched_priority = 50; // 设置优先级
pthread_attr_setschedparam(&attr, &param);

复制代码

#include <iostream>
#include <pthread.h>
#include <unistd.h>
// 线程函数
void* thread_function(void* arg) {
std::cout << "Thread is running." << std::endl;
return nullptr;
}
int main() {
pthread_t thread;
pthread_attr_t attr;
// 初始化线程属性
pthread_attr_init(&attr);
// 设置栈大小为2MB
size_t stack_size = 2 * 1024 * 1024;
pthread_attr_setstacksize(&attr, stack_size);
// 设置调度策略为时间片轮转
pthread_attr_setschedpolicy(&attr, SCHED_RR);
// 设置优先级
struct sched_param param;
param.sched_priority = 50;
pthread_attr_setschedparam(&attr, &param);
// 使用设置好的属性创建线程
if (pthread_create(&thread, &attr, thread_function, nullptr)!= 0) {
std::cerr << "Failed to create thread" << std::endl;
return 1;
}
// 等待线程结束
if (pthread_join(thread, nullptr)!= 0) {
std::cerr << "Failed to join thread" << std::endl;
return 1;
}
// 销毁线程属性
pthread_attr_destroy(&attr);
return 0;
}

复制代码

#include <iostream>
#include <pthread.h>
#include <unistd.h>
using namespace std;
int j = 2;
void* pthread_fun(void *arg)
{
//自己设置为detached状态
//int ret = pthread_detach(pthread_self());
while(j--)
{
cout << " in pthread_task" << endl;
cout << *(int*)arg << endl;
sleep(1);
}
// 线程返回一个整数值
int* result = new int(42);
return static_cast<void*>(result);//pthread_exit(reinterpret_cast<void*>(result));
}
int main()
{
int ret = 0;
pthread_t tid = 0;
int argsend = 99;
int i = 3;
pthread_attr_t attr;
// 初始化线程属性
pthread_attr_init(&attr);
ret = pthread_create(&tid, NULL, pthread_fun, &argsend);
if(ret != 0)
{
cout << " pthread_create error" << endl;
return -1;
}
sched_param param;
// 获取线程属性中的调度参数
if (pthread_attr_getschedparam(&attr, &param) != 0) {
std::cerr << "Failed to get scheduling parameters." << std::endl;
return 1;
}
// 打印调度参数中的优先级
std::cout << "Scheduling priority: " << param.sched_priority << std::endl;
// 设置线程属性的分离状态为分离
ret = pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
if (ret != 0) {
cerr << "Failed to set detach state." << endl;
return -1;
}
while(i--)
{
cout << "pthread _create success" << endl;
sleep(2);
}
int detachstate;
// 获取线程属性的分离状态
if (pthread_attr_getdetachstate(&attr, &detachstate) != 0) {
std::cerr << "Failed to get detach state." << std::endl;
// 销毁线程属性对象
pthread_attr_destroy(&attr);
return 1;
}
// 根据分离状态输出相应信息
if (detachstate == PTHREAD_CREATE_JOINABLE) {
std::cout << "Thread is joinable." << std::endl;
} else if (detachstate == PTHREAD_CREATE_DETACHED) {
std::cout << "Thread is detached." << std::endl;
} else {
std::cout << "Unknown detach state." << std::endl;
}
// 销毁线程属性
pthread_attr_destroy(&attr);
return 0;
}

复制代码