线程 c++防止价值改变

Question

我使用 boosthread 创建 3 个线程，每次调用相同的函数并传递不同的参数。 例如 1/ thread.add(function, int a1, std::string b), thread.add(function, int a2, std::string b), thread.add(function, int a3, std::string b), thread.add(function, int a4, std::string b)

当线程内的全局值更改时，我不希望其他线程执行 并再次更改该值 例如 function(a,b){

if(该线程发生了某些事情) value = 5;

//如果什么也没发生 值=1； ？

如果一个线程获得值 5，那么我不希望其他线程干扰该值并使其返回到 1。我该如何执行此操作 谢谢。

也许做到这一点的方法是使用 boost:mutex 但我没有看到这样做有任何好处，因为这个值只是找到的 在 return 语句之前，我很可能使用了 boost join_all()。但这会降低效率。

Answer 1

我有一个例子可以帮助你。
它使用 C++11，但可以轻松转换为 Boost。

该算法很简单，它由两个主要部分组成：

1. 启动三个线程
2. 连接它们（等待它们完成）

每个线程的作用：

1. 做一些工作
2. 如果它之前从未被初始化过（FirstThreadToFinish）

初始化一个变量， 初始化器功能有效。
1.使用互斥锁来防止对共享变量的多次访问（保证该函数一次只能由一个线程访问）
2.如果变量尚未初始化，则使用线程名称对其进行初始化，并将布尔值设置为 true（变量已初始化）
3.否则什么也不做

#include "stdafx.h"
#include <thread>
#include <chrono>
#include <mutex>
#include <iostream>
#include <string>
using namespace std;

mutex m;//to synchronize the data properly
string FirstThreadToFinish;
bool IsInitialized;

//This function is called by the main thread: does the work and initializes the variable only once
int MyThreadFunction(int Duration, const string & ThreadName);

//this function does some work (put here what your thread is really supposed to do)
int DoSomeWork(int Duration);

//this function initializes the variable only once and does nothing otherwise
int InitializeVariableOnce(int Duration, const string & ThreadName);

//this function initializes the variable only once and does nothing otherwise
int InitializeVariableOnce(int Duration, const string & ThreadName)
{
    std::lock_guard<mutex> l(m);
    if (!IsInitialized)
    {
        FirstThreadToFinish=ThreadName;
        IsInitialized=true;
        cout<<"FirstThreadToFinish= "<<ThreadName<< ", IsInitialized= "<<IsInitialized<<endl;
    }
    return 0;
}

//this function does some work (put here what your thread is really supposed to do)
int DoSomeWork(int Duration)
{
    std::this_thread::sleep_for(std::chrono::seconds(Duration));
    return 0;
}

int MyThreadFunction(int Duration, const string & ThreadName)
{
    DoSomeWork(Duration);
    InitializeVariableOnce(Duration, ThreadName);
    return 0;
}

int main()
{
    //at the begining nothing is initialized
    FirstThreadToFinish="Uninitialized";
    IsInitialized=false;
    cout<< "FirstThreadToFinish= "<<FirstThreadToFinish << ", IsInitalized="<<IsInitialized<<endl; 

    cout<<"Now launching 3 threads= "<<endl;
    thread MyAThread(MyThreadFunction,1,"AThread");
    thread MyBThread(MyThreadFunction,2,"BThread");
    thread MyCThread(MyThreadFunction,3,"CThread");


    MyAThread.join();
    MyBThread.join();
    MyCThread.join();

    return 0;
}

希望有帮助，如果没有回答问题请随时告诉我