admin/RepoMain
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

commit 2025-09-07 00:27 add ZCppMainTest/ZtCThreadEx_002_MutexCond.cpp

Browse Source
This commit is contained in:
sauron
2025-09-07 00:27:38 +09:00
parent 28b6010c51
commit 154890d939
5 changed files with 257 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ZCppMain/ZCProcess_Win.H
View File

@ -2380,7 +2380,7 @@ namespace ZNsMain
{
if(::SleepConditionVariableCS(&mo_CondVar, &mo_CritSect, AI_Mili)==TRUE)
{
return ZNsEnum::ZEThread_OK; /*#####################################*/
return ZNsEnum::ZEThread_OK;
}/*
if(::SleepConditionVariableCS(&mo_CondVar, &mo_CritSect, AI_Mili)==TRUE)*/

10
ZCppMain/ZMainHeadEx.H
View File

@ -222,11 +222,11 @@ namespace ZNsMain
inline bool ZfPutEnv(const char* APC_EnvName, const char* APC_Value)
{
#if __VISUAL_CPP_VER__>=200500
#if __VISUAL_CPP_VER__>=200500
return ::_putenv_s(APC_EnvName, APC_Value)==0;
#else //__VISUAL_CPP_VER__<200500
#else //__VISUAL_CPP_VER__<=200500
std::string VO_CStringEnv;
@ -250,9 +250,9 @@ namespace ZNsMain
{
// 표준 출력에 쓴다.
DWORD VDW_WrittenSize=0;
DWORD VDW_WrittenSize= 0 ;
const bool CB_IsOK = //////////////////////////////////////////
const bool CB_IsOK = ////////////////////////////////////////
(
::WriteFile
(
@ -263,7 +263,7 @@ namespace ZNsMain
);
///////////////////////////////////////////////////////////////
if(CB_IsOK==false) return -1; return VDW_WrittenSize;
if(CB_IsOK==false) return -1; return VDW_WrittenSize;
}/*
inline long ZfWriteStdOut(LPCVOID APC_Buffer, DWORD ADW_BuffSize, LPOVERLAPPED AP_Overlapped=NULL)*/

14
ZCppMainTest/ZtCThreadEx_000.cpp
View File

@ -115,18 +115,22 @@ namespace ZNsMain
static int Main(int AI_ArgCnt=0, char* APP_ArgVal[]=0)
{
CThreadMy VO_CThreadMy ;
CThreadMy VO_CThreadMy1 ;
CThreadMy VO_CThreadMy2 ;
CThreadMy VO_CThreadMy3 ;
CThreadMy VO_CThreadMy4 ;
ZCStringStd VO_ZCStringStd1("Help Data1");
ZCStringStd VO_ZCStringStd2("Help Data2");
ZCStringStd VO_ZCStringStd3("Help Data3");
VO_CThreadMy.Make();
VO_CThreadMy1.Make();
cout<<"# Press Enter to continue."<<endl; cin.get();
VO_CThreadMy.Make(ZftMCP(VO_ZCStringStd1));
VO_CThreadMy2.Make(ZftMCP(VO_ZCStringStd1));
cout<<"# Press Enter to continue."<<endl; cin.get();
VO_CThreadMy.Make(ZftMCP(VO_ZCStringStd1), ZftMCP(VO_ZCStringStd2));
VO_CThreadMy3.Make(ZftMCP(VO_ZCStringStd1), ZftMCP(VO_ZCStringStd2));
cout<<"# Press Enter to continue."<<endl; cin.get();
VO_CThreadMy.Make(ZftMCP(VO_ZCStringStd1), ZftMCP(VO_ZCStringStd2), ZftMCP(VO_ZCStringStd3));
VO_CThreadMy4.Make(ZftMCP(VO_ZCStringStd1), ZftMCP(VO_ZCStringStd2), ZftMCP(VO_ZCStringStd3));
cout<<"# Press Enter to continue."<<endl; cin.get();
return 0;

13
ZCppMainTest/ZtCThreadEx_001.cpp
View File

@ -113,15 +113,18 @@ namespace ZNsMain
static int Main(int AI_ArgCnt=0, char* APP_ArgVal[]=0)
{
ZCThreadMy VO_CThreadMy ;
ZCThreadMy VO_CThreadMy1 ;
ZCThreadMy VO_CThreadMy2 ;
ZCThreadMy VO_CThreadMy3 ;
ZCThreadMy VO_CThreadMy4 ;
VO_CThreadMy.Make();
VO_CThreadMy1.Make();
cout<<"# Press Enter to continue."<<endl; cin.get();
VO_CThreadMy.Make(ZftMCP(ZCThreadMy::GI_CallCnt));
VO_CThreadMy2.Make(ZftMCP(ZCThreadMy::GI_CallCnt));
cout<<"# Press Enter to continue."<<endl; cin.get();
VO_CThreadMy.Make(ZftMCP(ZCThreadMy::GI_CallCnt), ZftMCP(ZCThreadMy::GI_CallCnt));
VO_CThreadMy3.Make(ZftMCP(ZCThreadMy::GI_CallCnt), ZftMCP(ZCThreadMy::GI_CallCnt));
cout<<"# Press Enter to continue."<<endl; cin.get();
VO_CThreadMy.Make(ZftMCP(ZCThreadMy::GI_CallCnt), ZftMCP(ZCThreadMy::GI_CallCnt), ZftMCP(ZCThreadMy::GI_CallCnt));
VO_CThreadMy4.Make(ZftMCP(ZCThreadMy::GI_CallCnt), ZftMCP(ZCThreadMy::GI_CallCnt), ZftMCP(ZCThreadMy::GI_CallCnt));
cout<<"# Press Enter to continue."<<endl; cin.get();
return 0;

234
ZCppMainTest/ZtCThreadEx_002_MutexCond.cpp Normal file
View File

@ -0,0 +1,234 @@

#ifndef _REENTRANT_EX
#define _REENTRANT_EX
#endif
#include <iostream>
#include "ZCppMain/ZCProcess.H"
#include "ZCppMain/ZMainHeadEx.H"
using namespace std ;
using namespace ZNsMain;
const int CI_RepeatCnt = 3 ;
const int CI_WaitMilli = 1000 ;
namespace ZNsMain
{
namespace ZNsExam
{
template<typename TDummy=void*> class ZtCExamThread_002
{
public:
typedef ZtCMutexCondData<> ZCMutexCondData;
public:
class ZCThreadMy : public ZNsMain::ZtCThreadEx<ZCThreadMy>
{
public :
typedef ZNsMain::ZtCThreadEx<ZCThreadMy> TypeBase;
public :
friend class ZNsMain:: ZtCThreadEx<ZCThreadMy>;
private:
void Init(ZCMutexCondData& AR_CMutexCond)
{
this->TypeBase::template Init<ZCMutexCondData&>(AR_CMutexCond);
/*@@@@@@@@@*/ AR_CMutexCond.Lock(); /*@@@@@@@@@*/
{
__for1(int, i, CI_RepeatCnt)
{
cout<<"# *** Thread Init "<<i<<endl; ZfSuspendExec(CI_WaitMilli);
}
/*::::::::::::::::::::::::*/
}
AR_CMutexCond.WakeCond();
AR_CMutexCond.WaitCond();
}/*
void Init(ZCMutexCondData& AR_CMutexCond)*/
void Exec(ZCMutexCondData& AR_CMutexCond)
{
this->TypeBase::template Exec<ZCMutexCondData&>(AR_CMutexCond);
{
__for1(int, i, CI_RepeatCnt)
{
cout<<"# >>> Thread Exec "<<i<<endl; ZfSuspendExec(CI_WaitMilli);
}
/*::::::::::::::::::::::::*/
}
AR_CMutexCond.WakeCond();
AR_CMutexCond.WaitCond();
}/*
void Exec(ZCMutexCondData& AR_CMutexCond)*/
void Fini(ZCMutexCondData& AR_CMutexCond)
{
this->TypeBase::template Fini<ZCMutexCondData&>(AR_CMutexCond);
{
__for1(int, i, CI_RepeatCnt)
{
cout<<"# *** Thread Fini "<<i<<endl; ZfSuspendExec(CI_WaitMilli);
}
/*::::::::::::::::::::::::*/
}
AR_CMutexCond.WakeCond();
/*@@@@@@@@@*/ AR_CMutexCond.UnLock(); /*@@@@@@@@@*/
}/*
void Fini(ZCMutexCondData& AR_CMutexCond)*/
private:
};/*
class ZCThreadMy : public ZNsMain::ZtCThreadEx<ZCThreadMy>*/
static int Main(int AI_ArgCnt=0, char* APP_ArgVal[]=0)
{
ZCMutexCondData VO_CMutexCond;
ZCThreadMy VO_CThreadMy ;
VO_CMutexCond.InitCond();
cout<<"- Mutex Init Cond" <<endl;
VO_CMutexCond.Lock ();
{
VO_CThreadMy.Make(ZftMCP(VO_CMutexCond));
cout<<"- Wait Thread Init"<<endl;
VO_CMutexCond.WaitCond();
{
__for1(int, i, CI_RepeatCnt)
{
cout<<"- Ack Thread Init "<<i<<endl; ZfSuspendExec(CI_WaitMilli);
}
}
VO_CMutexCond.WakeCond();
cout<<"- Wait Thread Exec"<<endl;
VO_CMutexCond.WaitCond();
{
__for1(int, i, CI_RepeatCnt)
{
cout<<"- Ack Thread Exec "<<i<<endl; ZfSuspendExec(CI_WaitMilli);
}
/*::::::::::::::::::::::::*/
}
VO_CMutexCond.WakeCond();
cout<<"- Wait Thread Fini"<<endl;
VO_CMutexCond.WaitCond();
{
__for1(int, i, CI_RepeatCnt)
{
cout<<"- Ack Thread Fini "<<i<<endl; ZfSuspendExec(CI_WaitMilli);
}
/*::::::::::::::::::::::::*/
}
}
VO_CMutexCond.UnLock();
VO_CMutexCond.FiniCond(); cout<<"- Mutex Fini Cond" <<endl;
return 0;
}/*
static int Main(int AI_ArgCnt=0, char* APP_ArgVal[]=0)*/
public:
};/*
template<typename TDummy=void*> class ZtCExamThread_002*/
}/*
namespace ZNsExam*/
}/*
namespace ZNsMain*/
int main(int AI_ArgCnt, char* APP_ArgVal[])
{
return ZNsMain::ZNsExam::
ZtCExamThread_002<>::Main(AI_ArgCnt, APP_ArgVal);
}/*
int main(int AI_ArgCnt, char* APP_ArgVal[])*/
/*////////////////////////////////////////////////////////////////////////////////////////
■ cigwin 컴파일
// g++ -mno-cygwin -o ZtCThreadEx_002_MutexCond.exe ZtCThreadEx_002_MutexCond.cpp -I../../my_CPP/CPP_Main/ -I../../my_CPP/CPP_Std/ -D__CYGWIN32__ -D__VISUAL_CPP_VER__=200300
// g++ -mno-cygwin -o ZtCThreadEx_002_MutexCond_D.exe ZtCThreadEx_002_MutexCond.cpp -I../../my_CPP/CPP_Main/ -I../../my_CPP/CPP_Std/ -D__CYGWIN32__ -D__VISUAL_CPP_VER__=200300 -D_DEBUG
■ mingw 컴파일
g++.exe -std=c++98 -o ZtCThreadEx_002_MutexCond_mw.exe ZtCThreadEx_002_MutexCond.cpp -I../ -lWs2_32
g++.exe -std=c++98 -o ZtCThreadEx_002_MutexCond_mw_D.exe ZtCThreadEx_002_MutexCond.cpp -I../ -lWs2_32 -D_DEBUG
./ZtCThreadEx_002_MutexCond_mw.exe
./ZtCThreadEx_002_MutexCond_mw_D.exe
Administrator@q381-2673 UCRT64 /e/my_CPP/ZCpp/ZCppMainTest
# date
Sun Aug 24 10:47:09 KST 2025
Administrator@q381-2673 UCRT64 /e/my_CPP/ZCpp/ZCppMainTest
# g++ --version
g++.exe (Rev2, Built by MSYS2 project) 13.2.0
Copyright (C) 2023 Free Software Foundation, Inc.
This is free software; see the source for copying conditions. There is NO
warranty; not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
■ Linux 컴파일
g++ -std=c++98 -o ZtCThreadEx_002_MutexCond.exe ZtCThreadEx_002_MutexCond.cpp -I../ -lpthread
g++ -std=c++98 -o ZtCThreadEx_002_MutexCond_D.exe ZtCThreadEx_002_MutexCond.cpp -I../ -lpthread -D_DEBUG
sauron@q381-2673:/mnt/e/my_CPP/ZCpp/ZCppMainTest$ gcc --version
gcc (Ubuntu 9.4.0-1ubuntu1~20.04.2) 9.4.0
Copyright (C) 2019 Free Software Foundation, Inc.
This is free software; see the source for copying conditions. There is NO
warranty; not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
sauron@q381-2673:/mnt/e/my_CPP/ZCpp/ZCppMainTest$ date
Sun Aug 24 00:05:51 DST 2025
sauron@q381-2673:/mnt/e/my_CPP/ZCpp/ZCppMainTest$ cat /etc/os-release
NAME="Ubuntu"
VERSION="20.04.6 LTS (Focal Fossa)"
ID=ubuntu
ID_LIKE=debian
PRETTY_NAME="Ubuntu 20.04.6 LTS"
VERSION_ID="20.04"
HOME_URL="https://www.ubuntu.com/"
SUPPORT_URL="https://help.ubuntu.com/"
BUG_REPORT_URL="https://bugs.launchpad.net/ubuntu/"
PRIVACY_POLICY_URL="https://www.ubuntu.com/legal/terms-and-policies/privacy-policy"
VERSION_CODENAME=focal
UBUNTU_CODENAME=focal
[sauron@q381-2657 ZCppMainTest]$ cat /etc/centos-release
CentOS Linux release 7.9.2009 (Core)
[sauron@q381-2657 ZCppMainTest]$ g++ --version
g++ (GCC) 4.8.5 20150623 (Red Hat 4.8.5-44)
Copyright (C) 2015 Free Software Foundation, Inc.
This is free software; see the source for copying conditions. There is NO
warranty; not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
■ 실행
./ZtCThreadEx_002_MutexCond.exe
./ZtCThreadEx_002_MutexCond_D.exe
////////////////////////////////////////////////////////////////////////////////////////*/