生产者消费者程序问题！

//******************************************************************************// //*                 实验一    生产者消费者问题                                 *// //******************************************************************************// 
 #include  #include  #include  typedef HANDLE SEMAPHORE; #define P(S) WaitForSingleObject(S,INFINITE); #define V(S) ReleaseSemaphore(S,1,NULL); 
 const unsigned short SIZE_OF_BUFFER = 10; //缓冲区长度 unsigned short ProductID = 0;    //产品号 unsigned short ConsumeID = 0;    //将被消耗的产品号 unsigned short in = 0;      //产品进缓冲区时的缓冲区下标 unsigned short out = 0;      //产品出缓冲区时的缓冲区下标 
 struct node//定义链表的一个结点 {  int data;  node* next; }; 
 class CircleLinkList { public:  node *CreateCircleLinkList();  void DeleteCircleLinkList(node *pLinkList); private:  node *currentNode,*headNode; }; 
 node* CircleLinkList::CreateCircleLinkList()//创建循环链表 {  node *s;  if(SIZE_OF_BUFFER>=1)  {   headNode=new node;   headNode->data=0;   currentNode=headNode;   for(int i=1;i<=SIZE_OF_BUFFER-1;i++)   {    s=new node;    s->data=0;    currentNode->next=s;    s->next=currentNode->next;    currentNode=s;       }   currentNode->next=headNode;   return headNode;  }  else  {   return NULL;  } } 
 void CircleLinkList::DeleteCircleLinkList(node* pLinkList)//释放链表所用内存 {  if(SIZE_OF_BUFFER>=1)  {   headNode=pLinkList;   currentNode=headNode->next;   delete headNode;      for(int i=1;i<=SIZE_OF_BUFFER-1;i++)   {    headNode=currentNode;    currentNode=currentNode->next;    delete headNode;   }  } } 
 bool g_continue = true;      //控制程序结束 HANDLE g_hMutex;       //用于线程间的互斥 HANDLE g_hEmptySemaphore;     //当缓冲区满时迫使生产者等待 HANDLE g_hFullSemaphore;     //当缓冲区空时迫使消费者等待 
 DWORD WINAPI Producer(LPVOID);    //生产者线程 DWORD WINAPI Consumer(LPVOID);    //消费者线程 
 node* pLinkList,*pIn,*pOut;//定义链表的头结点，可放下一个产品的结点，下一个可取出产品消费的结点 
 int main() {  //新建一个文件，用于记录生产者消费者访问缓冲区的过程  FILE *fp;  if((fp=fopen("1.txt","w"))==NULL)  {   cout<<"错误,文件打不开,请检查文件名"<data=ProductID;     pIn=pIn->next; 
     //输出缓冲区当前的状态  node *currentList=pLinkList;     for (int i=0;idata);     cout<data;         if (currentList==pIn)   {    fprintf(fp, " <-- 可放下一个产品的位置");    cout<<" <-- 可放下一个产品的位置";   }         if (currentList==pOut )   {    fprintf(fp," <-- 下一个可取出产品消费的位置");     cout<<" <-- 下一个可取出产品消费的位置";   }         fprintf(fp,"\n");   cout<next;     }  fclose(fp); } 
 //从缓冲区中取出一个产品 void TakeFromBuffer() {  //已"a"（追加内容）的形式打开文件，将新的缓冲区情况写入文件  FILE *fp;  if((fp=fopen("1.txt","a"))==NULL)  {   cout<<"错误,文件打不开,请检查文件名"<data; 
  pOut->data=0; 
     pOut=pOut->next; 
  if(ConsumeID%10==1)  {   fprintf(fp,"\nConsume the %dst product from buffer... \n",ConsumeID);     cout<<"\nConsume the "<data);     cout<data;         if (currentList==pIn)   {    fprintf(fp, " <-- 可放下一个产品的位置");    cout<<" <-- 可放下一个产品的位置";   }         if (currentList==pOut )   {     fprintf(fp, " <-- 下一个可取出产品消费的位置");     cout<<" <-- 下一个可取出产品消费的位置";    }         fprintf(fp,"\n");  cout<next;     }  fclose(fp); } 
 //生产者 DWORD  WINAPI Producer(LPVOID lpPara) {     while(g_continue)  {         P(g_hEmptySemaphore);         P(g_hMutex);             AddToBuffer();   Sleep(500);         V(g_hMutex);         V(g_hFullSemaphore);     }     return 0; } 
 //消费者 DWORD  WINAPI Consumer(LPVOID lpPara) {     while(g_continue)  {         P(g_hFullSemaphore);         P(g_hMutex);         TakeFromBuffer();   Sleep(500);         V(g_hMutex);         V(g_hEmptySemaphore);     }      return 0; } 
   
 这个程序能运行，但是一到生产者6就会卡在那里不会动，是什么问题？应该如何修改？