-
Notifications
You must be signed in to change notification settings - Fork 44
/
Copy path01_basic_thread.cpp
86 lines (74 loc) · 2.07 KB
/
01_basic_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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
/*
* Copyright(c) 2019 Jiau Zhang
* For more information see <https://github.com/JiauZhang/algorithms>
*
* This repo is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation
*
* It is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with THIS repo. If not, see <http://www.gnu.org/licenses/>.
*/
#include <boost/thread.hpp>
#include <iostream>
/*
主线程:
boost::thread::sleep(boost::get_system_time()
+ boost::posix_time::seconds(5));
子线程:
boost::this_thread::sleep(boost::get_system_time()
+ boost::posix_time::seconds(2));
*/
void wait(int seconds)
{
boost::thread::sleep(boost::get_system_time() + boost::posix_time::seconds(seconds));
}
void parallel_thread()
{
for (int i = 0; i < 5; ++i)
{
wait(1);
std::cout << "parallel thread: " << i << std::endl;
}
}
void current_thread()
{
for (int i = 0; i < 5; ++i)
{
wait(1);
std::cout << "current thread: " << i << std::endl;
}
}
/*
输出结果:
start mian function
thread has instanced
parallel thread: current thread: 0
0
current thread: 1
parallel thread: 1
current thread: parallel thread: 22
parallel thread: 3
current thread: 3
parallel thread: 4
current thread: 4
thread has exit
结果分析:
可以看出,两个线程的输出混在了一起,这是因为它们在抢占同一个资源
即输出资源,为了避免这种情况,就需要使用信号量了
*/
int main()
{
std::cout << "start mian function" << std::endl;
boost::thread t(parallel_thread);
std::cout << "thread has instanced" << std::endl;
current_thread();
t.join();
std::cout << "thread has exit" << std::endl;
return 0;
}