kenlistian

這是我做的測試例子，考慮到一個線程用于去讀數(shù)據(jù)庫，一次性插入多條數(shù)據(jù)到共享數(shù)據(jù)區(qū)，另外搞2個上的線程去讀這個共享數(shù)據(jù)區(qū)，以后打算搞個線程池來處理讀部分。

目下的問題是我想把這個共享數(shù)據(jù)區(qū)做成可變化的動態(tài)區(qū)，當讀入數(shù)據(jù)大時，一次讀入全部讀完。當數(shù)據(jù)量小時，則在規(guī)范范圍的空間中運行。

采用vector<mystructData>方式動態(tài)變化，比如要刪除超過長度之外的設(shè)置，只需要earse就可以了，在線程中每次通過begin，end自動掃描處理中數(shù)據(jù)部分。

如果把線程部分放到dll中，那么考慮到如何讀取共享數(shù)據(jù)區(qū)，采用導(dǎo)出函數(shù)方式，把主線程中的一個函數(shù)地址傳入到dll中，然后在這個函數(shù)中通過

find_if(a.begin(),a.end(),myfunc)照樣可以處理dll中跑線程的問題，之所以考慮用dll分離各個線程部分，是考慮到業(yè)務(wù)不同時，每個dll處理掃描共享數(shù)據(jù)區(qū)，發(fā)現(xiàn)自己的業(yè)務(wù)就去處理，不是則不理會，這樣考慮設(shè)計可以通過編寫dll方式來擴展不同的業(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;
}

//讀線程，讀完對IsGet標志為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;             //可以寫入標志
  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;
}