线程之间同步堆栈

Question

我在客户端（使用GUI和套接字）上工作。 GUI（在主线程上运行）随时创建我的协议的命令，每当我创建一个新命令时，我都会将它添加到动态堆栈中。

在另一个线程（使用pthread）中，我检查堆栈中是否有命令，然后使用套接字（它是非块btw）逐步发送它。当堆栈顶部的命令完成发送时，弹出堆栈（这意味着该命令被删除，并且第一个元素下面的每个命令都被推送）。

现在，你可能会猜到我有很大的问题来同步...我尝试使用一些标志，互斥锁，但我总是以内存访问冲突结束。

基本上什么Im做是这样的：

在主线程时（即）用户按下一个按钮：

char cmd[ 50 ] = "My new protocol command"; 

AppendCommandToSendStack(cmd); 

在另一个线程：

if(SendStackCount) 
{ 
    SendCommand(0); // 0 = The top of the stack. 

    if(IsCommandDoneSending(0)) 
    { 
      RemoveCommandFromStack(0); 
    } 
} 

能

人帮助我或给我一些关于如何使这个机制工作的指针。或者另一种可能导致与我试图实现的工作流相同或相似的方法。

Tks提前！

[更新]

我开始阅读旗语和它到底似乎这就是我所需要的...但它似乎并不工作...这是林在做伪代码：

sem_t mutex; 

int stack_count; 

command *stack; 

main() 
{ 
    // Init & Connect client. 

    // Start Thread 

    sem_init(&lock_stack, 0, 1); 

    while(1) 
    { 
     sem_wait(&lock_stack); 

     ++stack_count; 

     stack = (command *) realloc(stack, stack_count * sizeof(command)); 

     strcpy(stack[ stack_count - 1 ].cmd, "new command"); 

     sem_post(&lock_stack); 
    } 
} 


thread() 
{ 
    while(1) 
    { 
     sem_wait(&lock_stack); 

     if(stack_count) 
     { 
      // Send stack[ 0 ].cmd via socket then when done pop the stack like this: 

      --stack_count; 

      if(0 < stack_count) 
      { 
       memcpy(&stack[ 0 ], 
        &stack[ 1 ], 
        (stack_count - 1) * sizeof(command)); 
      }   
     } 

     sem_post(&lock_stack); 
    } 
} 

因为我基本上是新来的这个，我错过了一些明显的东西，因为我仍然有内存访问冲突，“似乎”随机发生在堆栈数组上。

Answer 1

你有生产者 - 消费者问题的典型例子。你想要produce命令，而其他线程consume他们。你可以看看http://en.wikipedia.org/wiki/Producer-consumer_problem，它解释了如何实现一个基本的生产者 - 消费者问题。

Answer 2

一个简单的解决方案将是：

Thread 1 : 
     lock mutex 
     put items on stack 
     unlock mutex 


    Thread 2 : 
    loop 
     lock mutex 
     check item on stack 
     if somthing get item on stack 
     unlock mutex 

一个更有效的soultion将是：

Thread 1 : 
     lock mutex 
     put items on stack 
     signal on conditionVariable 
     unlock mutex 

Thread 2 : 
     lock mutex 
     check item on stack 
     if none wait on conditionVariable 
     // here you will be woke up when there is a signal 
     get item on the stack 
     unlock mutex 
     do your work