多线程(multithreading),是指在软件或者硬件上实现多个线程并发执行的技术。具有多核CPU的支持的计算机能够真正在同一时间执行多个程序片段,进而提升程序的处理性能。在一个程序中,这些独立运行的程序片段被称为“线程”(Thread),利用其编程的概念就叫作“多线程处理”。
进程是指一个程序的运行实例,而线程是指进程中独立的执行流程。一个进程可以有多个线程,多个线程之间可以并发执行。
C++支持多线程编程,主要使用的是线程库<thread>
。
示例1: 创建线程使用std::thread
类
#include <iostream>
#include <thread> //必须包含<thread>头文件
void threadFunctionA()
{
std::cout << "Run New thread: 1" << std::endl;
}
void threadFunctionB(int n)
{
std::cout << "Run New thread: "<< n << std::endl;
}
int main()
{
std::cout << "Run Main Thread" << std::endl;
std::thread newThread1(threadFunctionA);
std::thread newThread2(threadFunctionB,2);
newThread1.join();
newThread2.join();
return 0;
}
//result
Run Main Thread
Run New thread: 1
Run New thread: 2
上述示例中,我们创建了两个线程newThread1和newThread2,使用函数threadFunctionA()
和threadFunctionB()
作为线程的执行函数,并使用join()
函数等待线程执行完成。
示例2: 执行函数有引用参数
#include <iostream>
#include <thread> //必须包含<thread>头文件
void threadFunc(int &arg1, int arg2)
{
arg1 = arg2;
std::cout << "arg1 = " << arg1 << std::endl;
}
int main()
{
std::cout << "Run Main Thread!" << std::endl;
int a = 1;
int b = 5;
std::thread newTh(threadFunc, a, b); //此处会报错
newTh.join();
return 0;
}
注意: 若编译上述代码,编译器会报如下错误:
错误 C2672 “std::invoke”: 未找到匹配的重载函数
错误 C2893 未能使函数模板“unknown-type std::invoke(_Callable &&,_Types &&...) noexcept(<expr>)”专用化
这是因为thread在传递参数时,是以右值传递的,如果要传递一个左值可以使用std::ref
和std::cref
std::ref
可以包装按引用传递的值为右值。std::cref
可以包装按const
引用传递的值为右值。因此,示例2代码可修改为:
#include <iostream>
#include <thread> //必须包含<thread>头文件
void threadFunc(int &arg1, int arg2)
{
arg1 = arg2;
std::cout << "New Thread arg1 = " << arg1 << std::endl;
}
int main()
{
std::cout << "Run Main Thread!" << std::endl;
int a = 1, b = 5;
std::thread newTh(threadFunc, std::ref(a), b); //使用ref
newTh.join();
return 0;
}
//result
Run Main Thread!
arg1 = 5
在C++中,创建了一个线程时,它通常被称为一个可联接(joinable)
的线程,可以通过调用join()
函数或detach()
函数来管理线程的执行。
方法 | 说明 | |
---|---|---|
1 | join() | 等待一个线程完成,如果该线程还未执行完毕,则当前线程(一般是主线程)将被阻塞,直到该线程执行完成,主线程才会继续执行。 |
2 | detach() | 将当前线程与创建的线程分离,使它们分别运行,当分离的线程执行完毕后,系统会自动回收其资源。如果一个线程被分离了,就不能再使用join() 函数了,因为线程已经无法被联接了。 |
3 | joinable() | 判断线程是否可以执行join() 函数,返回true/false |
示例3:
#include <iostream>
#include <thread>
#include <windows.h>
void foo()
{
std::cout << "Run New thread!\n";
Sleep(2000); //需要头文件<windows.h>
}
int main()
{
std::thread t(foo);
if (t.joinable())
{
t.join(); // 等待线程t执行完毕
// t.detach(); // 分离线程t与主线程
}
std::cout << "Run Main thread!\n";
return 0;
}
在上述的示例中,创建了一个可联接的线程t
,使用t.join()
主线程将被阻塞,直到t
线程执行完毕。如果使用t.detach()
将t
线程分离,那么它们将同时执行,主线程将不会阻塞。
注意:
join()
函数时才执行的,调用join()
函数只是阻塞等待线程结束并回收资源。detach()
的线程)会在调用它的线程结束或自己结束时自动释放资源。join()
或detach()
的线程在程序结束时会引发异常。在C++中,this_thread
类提供了一些关于当前线程的功能函数。具体如下:
使用 | 说明 | |
---|---|---|
1 | std::this_thread::sleep_for() | 当前线程休眠指定的时间 |
2 | std::this_thread::sleep_until() | 当前线程休眠直到指定时间点 |
3 | std::this_thread::yield() | 当前线程让出CPU,允许其他线程运行 |
4 | std::this_thread::get_id() | 获取当前线程的ID |
此外,this_thread
还包含重载运算符==
和!=
,用于比较两个线程是否相等。
示例4:
#include <iostream>
#include <thread>
#include <chrono>
void my_thread()
{
std::cout << "Thread " << std::this_thread::get_id() << " start!" << std::endl;
for (int i = 1; i <= 5; i++)
{
std::cout << "Thread " << std::this_thread::get_id() << " running: " << i << std::endl;
std::this_thread::yield(); // 让出当前线程的时间片
std::this_thread::sleep_for(std::chrono::milliseconds(200)); // 线程休眠200毫秒
}
std::cout << "Thread " << std::this_thread::get_id() << " end!" << std::endl;
}
int main()
{
std::cout << "Main thread id: " << std::this_thread::get_id() << std::endl;
std::thread t1(my_thread);
std::thread t2(my_thread);
t1.join();
t2.join();
return 0;
}
//result 程序输出的结果可能如下:
Main thread id: 43108
Thread 39272 start!
Thread 33480 start!
Thread 33480 running: 1
Thread 39272 running: 1
Thread 33480 running: 2
Thread 39272 running: 2
Thread 33480 running: 3
Thread 39272 running: 3
Thread 33480 running: 4
Thread 39272 running: 4
Thread 39272 running: 5
Thread 33480 running: 5
Thread 39272 ends
Thread 33480 ends
在多线程编程中,需要注意以下问题:
std::mutex
是 C++11 中最基本的互斥量,一个线程将mutex锁住时,其它的线程就不能操作mutex,直到这个线程将mutex解锁。
方法 | 说明 | |
---|---|---|
1 | lock() | 将mutex上锁。如果mutex已经被其它线程上锁,那么会阻塞,直到解锁;如果mutex已经被同一个线程锁住,那么会产生死锁。 |
2 | unlock() | 将mutex解锁,释放其所有权。如果有线程因为调用lock() 不能上锁而被阻塞,则调用此函数会将mutex的主动权随机交给其中一个线程;如果mutex不是被此线程上锁,那么会引发未定义的异常。 |
3 | try_lock() | 尝试将mutex上锁。如果mutex未被上锁,则将其上锁并返回true;如果mutex已被锁则返回false。 |
示例: 使用互斥量
#include <iostream>
#include <thread>
#include <mutex>
std::mutex mtx;
int num = 0;
void thread_function(int &n)
{
for (int i = 0; i < 100; ++i)
{
mtx.lock();
n++;
mtx.unlock();
}
}
int main()
{
std::thread myThread[500];
for (std::thread &a : myThread)
{
a = std::thread(thread_function, std::ref(num));
a.join();
}
std::cout << "num = " << num << std::endl;
std::cout << "Main thread exits!" << std::endl;
return 0;
}
//result
num = 50000
Main thread exits!
注意: 在使用互斥量时,需要注意以下问题:
std::mutex
来控制对共享资源的访问,因此可能会对程序的性能造成影响,如果需要优化程序性能,可以考虑使用无锁编程等技术。std::lock_guard
是C++标准库中的一个模板类,用于实现资源的自动加锁和解锁。它是基于RAII(资源获取即初始化)的设计理念,能够确保在作用域结束时自动释放锁资源,避免了手动管理锁的复杂性和可能出现的错误。
std::lock_guard
的主要特点如下:
std::lock_guard
对象时,会立即对指定的互斥量进行加锁操作。这样可以确保在进入作用域后,互斥量已经被锁定,避免了并发访问资源的竞争条件。std::lock_guard
对象在作用域结束时,会自动释放互斥量。无论作用域是通过正常的流程结束、异常抛出还是使用return
语句提前返回,std::lock_guard
都能保证互斥量被正确解锁,避免了资源泄漏和死锁的风险。std::lock_guard
是通过栈上的对象实现的,因此适用于在局部范围内锁定互斥量。当超出std::lock_guard
对象的作用域时,互斥量会自动解锁,释放控制权。使用std::lock_guard
的一般步骤如下:
std::lock_guard
对象,传入要加锁的互斥量作为参数。std::lock_guard
对象的作用域结束时,自动调用析构函数解锁互斥量。示例:
#include <iostream>
#include <thread>
#include <mutex>
std::mutex mtx; // 互斥量
void thread_function()
{
std::lock_guard<std::mutex> lock(mtx); // 加锁互斥量
std::cout << "Thread running" << std::endl;
// 执行需要加锁保护的代码
} // lock_guard对象的析构函数自动解锁互斥量
int main()
{
std::thread t1(thread_function);
t1.join();
std::cout << "Main thread exits!" << std::endl;
return 0;
}
在上述示例中,std::lock_guard
对象lock
会在thread_function
中加锁互斥量,保护了输出语句的执行。当thread_function
结束时,lock_guard
对象的析构函数会自动解锁互斥量。这样可以确保互斥量在合适的时候被锁定和解锁,避免了多线程间的竞争问题。
总而言之,std::lock_guard
提供了一种简单而安全的方式来管理互斥量的锁定和解锁,使多线程编程更加方便和可靠。
std::unique_lock
是C++标准库中的一个模板类,用于实现更加灵活的互斥量的加锁和解锁操作。它提供了比std::lock_guard
更多的功能和灵活性。
std::unique_lock
的主要特点如下:
自动加锁和解锁: 与std::lock_guard
类似,std::unique_lock
在创建对象时立即对指定的互斥量进行加锁操作,确保互斥量被锁定。在对象的生命周期结束时,会自动解锁互斥量。这种自动加锁和解锁的机制避免了手动管理锁的复杂性和可能出现的错误。
支持灵活的加锁和解锁: 相对于std::lock_guard
的自动加锁和解锁,std::unique_lock
提供了更灵活的方式。它可以在需要的时候手动加锁和解锁互斥量,允许在不同的代码块中对互斥量进行多次加锁和解锁操作。
支持延迟加锁和条件变量:std::unique_lock
还支持延迟加锁的功能,可以在不立即加锁的情况下创建对象,稍后根据需要进行加锁操作。此外,它还可以与条件变量(std::condition_variable
)一起使用,实现更复杂的线程同步和等待机制。
使用std::unique_lock
的一般步骤如下:
std::unique_lock
对象,传入要加锁的互斥量作为参数。lock
函数对互斥量进行加锁,或者在需要时调用unlock
函数手动解锁互斥量。示例:
#include <iostream>
#include <thread>
#include <mutex>
std::mutex mtx; // 互斥量
void thread_function()
{
std::unique_lock<std::mutex> lock(mtx); // 加锁互斥量
std::cout << "Thread running" << std::endl;
// 执行需要加锁保护的代码
lock.unlock(); // 手动解锁互斥量
// 执行不需要加锁保护的代码
lock.lock(); // 再次加锁互斥量
// 执行需要加锁保护的代码
}
// unique_lock对象的析构函数自动解锁互斥量
int main()
{
std::thread t1(thread_function);
t1.join();
std::cout << "Main thread exits!" << std::endl;
return 0;
}
在上述示例中,std::unique_lock
对象lock
会在创建时自动加锁互斥量,析构时自动解锁互斥量。我们可以通过调用lock
和unlock
函数手动控制加锁和解锁的时机,以实现更灵活的操作。
总而言之,std::unique_lock
提供了更灵活和功能丰富的互斥量的加锁和解锁机制,使多线程编程更加便捷和安全。它在处理复杂的同步需求、延迟加锁以及与条件变量的结合等方面非常有用。
std::condition_variable
是C++标准库中的一个类,用于在多线程编程中实现线程间的条件变量和线程同步。它提供了等待和通知的机制,使得线程可以等待某个条件成立时被唤醒,或者在满足某个条件时通知其他等待的线程。其提供了以下几个函数用于等待和通知线程:
方法 | 说明 | |
---|---|---|
1 | wait | 使当前线程进入等待状态,直到被其他线程通过notify_one() 或notify_all() 函数唤醒。该函数需要一个互斥锁作为参数,调用时会自动释放互斥锁,并在被唤醒后重新获取互斥锁。 |
2 | wait_for | wait_for() : 使当前线程进入等待状态,最多等待一定的时间,直到被其他线程通过notify_one() 或notify_all() 函数唤醒,或者等待超时。该函数需要一个互斥锁和一个时间段作为参数,返回时有两种情况:等待超时返回std::cv_status::timeout ,被唤醒返回std::cv_status::no_timeout 。 |
3 | wait_until | wait_until() : 使当前线程进入等待状态,直到被其他线程通过notify_one() 或notify_all() 函数唤醒,或者等待时间达到指定的绝对时间点。该函数需要一个互斥锁和一个绝对时间点作为参数,返回时有两种情况:时间到达返回std::cv_status::timeout ,被唤醒返回std::cv_status::no_timeout 。 |
4 | notify_one | notify_one() : 唤醒一个等待中的线程,如果有多个线程在等待,则选择其中一个线程唤醒。 |
5 | notify_all | notify_all() : 唤醒所有等待中的线程,使它们从等待状态返回。 |
std::condition_variable
的主要特点如下:
等待和通知机制:std::condition_variable
允许线程进入等待状态,直到某个条件满足时才被唤醒。线程可以调用wait
函数进入等待状态,并指定一个互斥量作为参数,以确保线程在等待期间互斥量被锁定。当其他线程满足条件并调用notify_one
或notify_all
函数时,等待的线程将被唤醒并继续执行。
与互斥量配合使用:std::condition_variable
需要与互斥量(std::mutex
或std::unique_lock<std::mutex>
)配合使用,以确保线程之间的互斥性。在等待之前,线程必须先锁定互斥量,以避免竞争条件。当条件满足时,通知其他等待的线程之前,必须再次锁定互斥量。
支持超时等待:std::condition_variable
提供了带有超时参数的等待函数wait_for
和wait_until
,允许线程在等待一段时间后自动被唤醒。这对于处理超时情况或限时等待非常有用。
使用std::condition_variable
的一般步骤如下:
std::condition_variable
对象。std::mutex
或std::unique_lock<std::mutex>
)。std::unique_lock
锁定互斥量,并调用wait
函数进入等待状态。std::unique_lock
锁定互斥量,并调用notify_one
或notify_all
函数通知等待的线程。示例:
#include <iostream>
#include <thread>
#include <condition_variable>
std::mutex mtx; // 互斥量
std::condition_variable cv; // 条件变量
bool isReady = false; // 条件
void thread_function()
{
std::unique_lock<std::mutex> lock(mtx);
while (!isReady)
{
cv.wait(lock); // 等待条件满足
}
std::cout << "Thread is notified" << std::endl;
}
int main()
{
std::thread t(thread_function);
// 模拟一段耗时操作
std::this_thread::sleep_for(std::chrono::seconds(2));
{
std::lock_guard<std::mutex> lock(mtx);
isReady = true; // 设置条件为true
}
cv.notify_one(); // 通知等待的线程
t.join();
return 0;
}
上述示例中,创建了一个线程,该线程在等待状态下通过cv.wait(lock)
等待条件满足。主线程经过一段时间后将条件设置为true
,然后通过cv.notify_one()
通知等待的线程。等待的线程被唤醒后输出一条消息。
std::mutex
可以很好地解决多线程资源争抢的问题,但它每次循环都要加锁、解锁,这样固然会浪费很多的时间。
在 C++ 中,std::atomic
是用来提供原子操作的类,atomic,本意为原子,原子操作是最小的且不可并行化的操作。这就意味着即使是多线程,也要像同步进行一样同步操作原子对象,从而省去了互斥量上锁、解锁的时间消耗。
使用 std::atomic
可以保证数据在操作期间不被其他线程修改,这样就避免了数据竞争,使得程序在多线程并发访问时仍然能够正确执行。
示例:
#include <iostream>
#include <thread>
#include <mutex>
#include <atomic> //必须包含
std::atomic_int num = 0;
void thread_function(std::atomic_int &n) //修改类型
{
for (int i = 0; i < 100; ++i)
{
n++;
}
}
int main()
{
std::thread myThread[500];
for (std::thread &a : myThread)
{
a = std::thread(thread_function, std::ref(num));
a.join();
}
std::cout << "num = " << num << std::endl;
std::cout << "Main thread exits!" << std::endl;
return 0;
}
//result
num = 50000
Main thread exits!
说明:std::atomic_int
是std::atomic<int>
的别名。
文章浏览阅读1.3w次。转载自 http://www.miui.com/thread-2003672-1-1.html 当手机在刷错包或者误修改删除系统文件后会出现无法开机或者是移动定制(联通合约机)版想刷标准版,这时就会用到线刷,首先就是安装线刷驱动。 在XP和win7上线刷是比较方便的,用那个驱动自动安装版,直接就可以安装好,完成线刷。不过现在也有好多机友换成了win8/8.1系统,再使用这个_mt65驱动
文章浏览阅读1k次。SonarQube是一个代码质量管理平台,可以扫描监测代码并给出质量评价及修改建议,通过插件机制支持25+中开发语言,可以很容易与gradle\maven\jenkins等工具进行集成,是非常流行的代码质量管控平台。通CheckStyle、findbugs等工具定位不同,SonarQube定位于平台,有完善的管理机制及强大的管理页面,并通过插件支持checkstyle及findbugs等既有的流..._sonar的客户端区别
文章浏览阅读3.4k次,点赞2次,收藏27次。神经图灵机是LSTM、GRU的改进版本,本质上依然包含一个外部记忆结构、可对记忆进行读写操作,主要针对读写操作进行了改进,或者说提出了一种新的读写操作思路。神经图灵机之所以叫这个名字是因为它通过深度学习模型模拟了图灵机,但是我觉得如果先去介绍图灵机的概念,就会搞得很混乱,所以这里主要从神经图灵机改进了LSTM的哪些方面入手进行讲解,同时,由于模型的结构比较复杂,为了让思路更清晰,这次也会分开几..._神经图灵机方法改进
文章浏览阅读2.8k次。一、模型迭代方法机器学习模型在实际应用的场景,通常要根据新增的数据下进行模型的迭代,常见的模型迭代方法有以下几种:1、全量数据重新训练一个模型,直接合并历史训练数据与新增的数据,模型直接离线学习全量数据,学习得到一个全新的模型。优缺点:这也是实际最为常见的模型迭代方式,通常模型效果也是最好的,但这样模型迭代比较耗时,资源耗费比较多,实时性较差,特别是在大数据场景更为困难;2、模型融合的方法,将旧模..._模型迭代
文章浏览阅读2.3k次。1、前言上传图片一般采用异步上传的方式,但是异步上传带来不好的地方,就如果图片有改变或者删除,图片服务器端就会造成浪费。所以有时候就会和参数同步提交。笔者喜欢base64图片一起上传,但是图片过多时就会出现数据丢失等异常。因为tomcat的post请求默认是2M的长度限制。2、解决办法有两种:① 修改tomcat的servel.xml的配置文件,设置 maxPostSize=..._base64可以装换zip吗
文章浏览阅读1k次,点赞17次,收藏22次。Opencv自然场景文本识别系统(源码&教程)_opencv自然场景实时识别文字
文章浏览阅读1.3k次。拷贝虚拟机文件时间比较长,因为虚拟机 flat 文件很大,所以要等。脚本完成后,以复制虚拟机文件夹。将以下脚本内容写入文件。_exsi6.7快速克隆centos
文章浏览阅读2k次。本文主要实现基于二度好友的推荐。数学公式参考于:http://blog.csdn.net/qq_14950717/article/details/52197565测试数据为自己随手画的关系图把图片整理成文本信息如下:a b c d e f yb c a f gc a b dd c a e h q re f h d af e a b gg h f bh e g i di j m n ..._本关任务:使用 spark core 知识完成 " 好友推荐 " 的程序。
文章浏览阅读367次。南京大学高级程序设计期末复习总结,c++面向对象编程_南京大学高级程序设计
文章浏览阅读3.1k次,点赞2次,收藏12次。实现朴素贝叶斯分类器,并且根据李航《统计机器学习》第四章提供的数据训练与测试,结果与书中一致分别实现了朴素贝叶斯以及带有laplace平滑的朴素贝叶斯%书中例题实现朴素贝叶斯%特征1的取值集合A1=[1;2;3];%特征2的取值集合A2=[4;5;6];%S M LAValues={A1;A2};%Y的取值集合YValue=[-1;1];%数据集和T=[ 1,4,-1;..._朴素贝叶斯 matlab训练和测试输出
文章浏览阅读1.6k次。Markdown 文本换行_markdowntext 换行
文章浏览阅读6.7w次,点赞2次,收藏37次。win10 2016长期服务版激活错误解决方法:打开“注册表编辑器”;(Windows + R然后输入Regedit)修改SkipRearm的值为1:(在HKEY_LOCAL_MACHINE–》SOFTWARE–》Microsoft–》Windows NT–》CurrentVersion–》SoftwareProtectionPlatform里面,将SkipRearm的值修改为1)重..._错误: 0xc0000022 在运行 microsoft windows 非核心版本的计算机上,运行“slui.ex