這是我做的測(cè)試?yán)樱紤]到一個(gè)線程用于去讀數(shù)據(jù)庫(kù)，一次性插入多條數(shù)據(jù)到共享數(shù)據(jù)區(qū)，另外搞2個(gè)上的線程去讀這個(gè)共享數(shù)據(jù)區(qū)，以后打算搞個(gè)線程池來(lái)處理讀部分。
目下的問(wèn)題是我想把這個(gè)共享數(shù)據(jù)區(qū)做成可變化的動(dòng)態(tài)區(qū)，當(dāng)讀入數(shù)據(jù)大時(shí)，一次讀入全部讀完。當(dāng)數(shù)據(jù)量小時(shí)，則在規(guī)范范圍的空間中運(yùn)行。
采用vector<mystructData>方式動(dòng)態(tài)變化，比如要?jiǎng)h除超過(guò)長(zhǎng)度之外的設(shè)置，只需要earse就可以了，在線程中每次通過(guò)begin，end自動(dòng)掃描處理中數(shù)據(jù)部分。
如果把線程部分放到dll中，那么考慮到如何讀取共享數(shù)據(jù)區(qū)，采用導(dǎo)出函數(shù)方式，把主線程中的一個(gè)函數(shù)地址傳入到dll中，然后在這個(gè)函數(shù)中通過(guò)
find_if(a.begin(),a.end(),myfunc)照樣可以處理dll中跑線程的問(wèn)題，之所以考慮用dll分離各個(gè)線程部分，是考慮到業(yè)務(wù)不同時(shí)，每個(gè)dll處理掃描共享數(shù)據(jù)區(qū)，發(fā)現(xiàn)自己的業(yè)務(wù)就去處理，不是則不理會(huì)，這樣考慮設(shè)計(jì)可以通過(guò)編寫(xiě)dll方式來(lái)擴(kuò)展不同的業(yè)務(wù)。
#include "stdafx.h"
#include
<vector>
#include <iostream>
#include
<windows.h>
#include <process.h>
#include
<algorithm>
using namespace std;
struct te
{
int IsGet;
int a1;
int
s1;
char b1[20];
};
bool isget(te t)
{
return t.IsGet ==1;
}
bool getdata(te
t)
{
return t.IsGet==0;
}
vector<te> a;
HANDLE
hMutex;
void myprint(te t)
{
cout<<" ALL
"<< (t.IsGet == 0? "Have": "No ")<<
"("<<t.a1<<")"<<t.s1<<" " << t.b1
<<endl;
}
DWORD WINAPI insertdata( LPVOID lpParam
)
{
vector<te>::iterator p;
int i =
0;
while (1)
{
do{
p =
find_if(a.begin(), a.end(), isget);
if (p!=
a.end())
{
WaitForSingleObject(hMutex,
INFINITE);
i++;
p->IsGet =
0;
p->s1 =
i;
sprintf(p->b1, "%s- %d", "thread_insert" ,
i);
cout<<"
insert("<<p->a1<<") " << p->s1<<" " <<
p->b1 <<endl;
ReleaseMutex(hMutex);
}
//Sleep(1000);
}
while(p !=
a.end());
WaitForSingleObject(hMutex,
INFINITE);
cout<<"---------------------------"<<endl;
for_each(a.begin(),
a.end(),
myprint);
ReleaseMutex(hMutex);
Sleep(11000);
}
return 0;
}
//讀線程，讀完對(duì)IsGet標(biāo)志為1
DWORD WINAPI processdata( LPVOID lpParam
)
{
vector<te>::iterator
p;
while(1)
{
WaitForSingleObject(hMutex,
INFINITE);
p = find_if(a.begin(), a.end(),
getdata);
if (p != a.end())
{
cout<<"("<< (char*)lpParam << ") get ("
<< p->a1<<") " << p->s1 <<" " << p->b1
<<endl;
p->IsGet =
1;
p->s1 = 0;
p->b1[0] =
'\0';
}
ReleaseMutex(hMutex);
Sleep(500);
}
return 0;
}
int main(int argc, char* argv[])
{
HANDLE
hInsertHandle, hProcessHandle1,hProcessHandle2;
DWORD dwThreadId;
te tt1;
for(int i = 0; i <
10;i++)
{
tt1.IsGet =
1;
//可以寫(xiě)入標(biāo)志
tt1.a1 = i;
tt1.s1 =
0;
sprintf(tt1.b1,"%d",
i);
a.push_back(tt1);
}
hMutex = CreateMutex(NULL, false, "mutex");
hInsertHandle = CreateThread(
NULL,
0,
insertdata,
NULL,
// argument to thread function
0,
// use default creation flags
&dwThreadId);
hProcessHandle1 = CreateThread(
//讀出線程1
NULL,
0,
processdata,
"proc1"
,
0,
&dwThreadId);
hProcessHandle2 = CreateThread(
NULL,
0,
processdata,
"proc2",
0,
&dwThreadId);
while(1)
{
printf("main thread
...\n");
char c = getchar();
if (c==
'q')
break;
}
return 0;
}