線程之間同步堆棧

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