网页资讯视频图片知道文库贴吧地图采购
进入贴吧全吧搜索
c++吧 关注：625,377贴子：2,112,460
  • 6回复贴，共1页

俩线程同访问同一int变量，一线程只读取，另一线程可读写，bug

两个线程同时访问同一个int型变量，一个线程只读取，另一线程可读写。感觉好像结果不正确，请高手解惑
//自定义线程过程
UINT __stdcall Thread_Fn(void* pParam)
{
int* p = (int*)pParam;
有语句释放信号，通知主线程继续;
while(1)
{
if(*p)
{ 退出线程;}
其他语句...;//这语句不会有死循环，也不会占太多时间
}
}
//问题：有时候，主线程里(*p)已经改成非0了，但线程Thread_Fn有时并不会停止，有很小的几率发生，但确实发生过好几次
//难道说：子线程读取(*p)的瞬间，会导致主线程读写该变量失败？
//主线程里：
int var_1 = 0;
HANDLE hThread_1 = (HANDLE)_beginthreadex(其他参数..., Thread_Fn, &var_1, 其他参数...);
有语句等hThread_1释放信号后再继续...;
//线程hThread_1没结束前，会一直循环，var_1不会回收
while(自定义判断线程运行中(hThread_1))
{
if(某些条件a)
{
var_1 = 0;
其他语句a;
}
else if(某些条件b)
{
var_1 = 1;
其他语句b;
}
else
{
var_1 = 2;
其他语句c;
}
}


struct context
{
volatile int val_1;
};
用上面的作为线程参数


2025-07-22 18:09:53
广告
不感兴趣
开通SVIP免广告
class context
{
public:
volatile int val;
context()
{
hEventWaitForWork = CreateEvent(nullptr, FALSE, FALSE, nullptr);
hEventAcceptWork = CreateEvent(nullptr, FALSE, FALSE, nullptr);
}
~context()
{
CloseHandle(hEventWaitForWork);
CloseHandle(hEventAcceptWork);
}
BOOL Exit() const
{
return bExit;
}
void SetExit()
{
InterlockedIncrement(&bExit);
}
void DoWork()
{
ResetEvent(hEventWaitForWork);
}
DWORD WaitForWork()
{
return WairForSingleObject(hEventWaitForWork, 100);
}
void AcceptWork()
{
ResetEvent(hEventAcceptWork);
}
DWORD WaitAccept()
{
return WaitForSingleObject(hEventAcceptWork, 100);
}
private:
volatile BOOL bExit = FALSE;
hEventWaitForWork;
hEventAcceptWork;
}
DWORD __stdcall ThreadProc(void *param)
{
context *ctx = (context*)param;
bool _continue = true;
DWORD _Ret = 0;
while (_continue)
{
DWORD dw = ctx->WaitForWork();
switch (dw)
{
case WAIT_OBJECT_0:
{
ctx->AcceptWork();
//do something;
break;
}
case WAIT_TIMEOUT:
{
if (ctx->Exit()) _continue = false;
break;
}
default:
_Ret = 1;
break;
}
}
return _Ret;
}
int main()
{
context ctx;
HANDLE hThread;
//...
const int taskCount = 100;
bool _Continue = true;
for (int i = 0; _Continue && i < taskCount; ++i)
{
//分配工作
ctx.DoWork();
while(true)
{
DWORD dw = ctx.WaitAccept();
if (dw == WAIT_OBJECT_0)
break;
else if (dw == WAIT_TIMEOUT &&
GetExitCodeThread(hThread) != STILL_ACTIVE)
{
_Continue = false;
break;
}
}
ctx.SetExit();
WaitForSingleObject(hThread);
return 0;
}


扫二维码下载贴吧客户端

下载贴吧APP
看高清直播、视频！
  • 6回复贴，共1页
分享到: