Linux 回调函数与线程共同访问全局变量,但结果不一样,太诡异了
#include "stdio.h"
#include <stdlib.h>
#include <unistd.h>
#include <iostream>
#include "CommonUtils.h"
#include "address.h"
#include "tcpserver.h"
#include "httpserver.h"
#include "httprequest.h"
#include "httpresponse.h"
#include "httpconnection.h"

using namespace std;
using namespace tnet;
using namespace std::placeholders;

//==================================================================//
//全局变量
std::vector<string> vecMessageQueque;

volatile int g_iVarTest = 0;

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
//==================================================================//

void onHandler(const HttpConnectionPtr_t& conn, const HttpRequest& request)
{
    printf("HTTP接收数据:%s\n" , request.body.c_str());

    g_iVarTest += 1;

    printf("变量值地址:%d\n" , g_iVarTest);
    //=============================================================//
    //构造应答
    HttpResponse resp;
    resp.statusCode = 200;
    resp.setContentType("text/html");
    resp.setKeepAlive(true);
    resp.enableDate();    
    resp.body.append("recvdata: success"); //json字符串
    conn->send(resp);
    //=============================================================//
}

//消息队列调度线程
void* MessageProcThread(void* lpParameter)
{
    int i = 0;
    char buffer[1024];
    while (true)
    {
        printf("消息处理数量:%d\n" , g_iVarTest);

        sleep(1);
    }
}

//消息队列调度线程
void* HttpServiceThread(void* lpParameter)
{
         TcpServer s;

        HttpServer httpd(&s);

         printf("HTTP服务启动正常...\n");

        httpd.setHttpCallback("/service/", std::bind(&onHandler, _1, _2));

        httpd.listen(Address(11181));

        s.start(4);
}

int main()
{
    //创建消息处理线程
    //========================================================//
    //传入的时候必须强制转换为void* 类型,即无类型指针
    pthread_t hMsgProcThread;
    pthread_create(&hMsgProcThread, NULL, MessageProcThread, NULL);

    //测试http服务
    //========================================================//
    pthread_t hHttpServiceThread;
    pthread_create(&hHttpServiceThread, NULL, HttpServiceThread, NULL);
    //========================================================//

    while (true )
    {
        char ch = getchar();
        if (ch =='#') break;
    }

    return 0;
}

图片说明

代码如上,g_iVarTest这个值已经改变,MessageProcThread线程访问的结果与onHandler回调的结果不一样,求高手解答以下!

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问