在一個正在運行的線程中處理一個事件

Question

我有一個運行在線程中的函數f1，並且它不斷地執行一個計算c1。

但是當一個特殊事件發生時，f1必須做計算c2（而不是計算c1）。

我該如何執行此操作？ 我已經搜索了很多，生產者 - 消費者案例或條件鎖不適合我的實現（我這麼認爲），因爲我不希望線程停止，直到事件發生。

任何人都可以幫我嗎？

預先感謝您

class myclass 
{ 
    void f1 (void) 
    { //I do not want the f1 stop, it has to do its work, and when f2 send an event to him, act different 
     while (1) { 
      if(there is an event from f2) 
       do c2; 
      else 
       do c1; 
      // I do not want to loose any event either 
     } 
    } 

    void f2(void) 
    {//f2 runs in parralel to f1 
    } 

    void execute() 
    { 
     // f1_thread do calculations (c1) continiously 
     boost::thread* f1_thread = new boost::thread(boost::bind(&myclass::f1, this)); 
     // f2_thread has to send an event to force the f1_thread (once a while) to do calculation c2 instead of c1 
     boost::thread* f2_thread = new boost::thread(boost::bind(&myclass::f2, this)); 
    } 
} 
int main() 
{ 
    myclass _myclass; 
    _myclass.execute(); 
} 

我想要的「F1」停止「C1」計算，並立即切換到計算C2每當「F2」給他發個信號（我不知道信號還）。計算c1非常耗時，如果我使用「if子句」，當事件發生時，「c2」直到「c1」結束才能運行。

Answer 1

在問題中給出更多信息之前，您是否對主題'簡單函數指針交換'進行了任何修改？

typedef void (*CALC_FUNC)(); 

void c1() { ... } 
void c2() { ... } 
volatile CALC_FUNC calcFunc; 

class myclass 
{ 
    void f1 (void) 
    { 
     while (1) { 
      // Provided that your platform's function pointer 
      // assigment is atomic (otherwise do an interlocked 
      // operation) 
      CALC_FUNC func = calcFunc; 
      func(); 
     } 
    } 

    void f2(void) 
    { 
     // Provided that your platform's function pointer 
     // assigment is atomic (otherwise do an interlocked 
     // operation) 
     if(someCondition) calcFunc = c2; 
     else if(someOtherCondition) calcFunc = c1; 
    } 

    void execute() 
    { 
     calcFunc = c1; 

     // f1_thread do calculations (c1) continiously 
     boost::thread* f1_thread = new boost::thread(boost::bind(&myclass::f1, this)); 
     // f2_thread has to send an event to force the f1_thread (once a while) to do calculation c2 instead of c1 
     boost::thread* f2_thread = new boost::thread(boost::bind(&myclass::f2, this)); 
    } 
}