C / C++ / MFC

While (count<10)
{
 myThread[threadCount].readLineInto(myLineArray[count]);
 threadCount++;if(threadCount>7) threadCount=0;
 count++;
}

CCriticalSection cs;
 
// ThreadA writes data to an array
cs.Lock();
// Write data to an array
cs.Unlock();
....
// ThreadB reads data to an array
cs.Lock();
// Read data from an array
cs.Unlock();

class MyThread : public Thread {
private:
    int m_nCount;
public:
    MyThread(int n,const char* nm) {
        Thread::setName(nm);
        m_nCount = n;
    }
    void run() {
        for(int i=0;i<m_nCount;i++) {
            cout << getName().c_str() << ":" << i << endl;
        }
    }
};


int main() {
    Thread *t1 = new MyThread(15,"Thread 01");
    Thread *t2 = new MyThread(10,"Thread 02");
    try {
        t1->start();
        t2->start();
        t1->stop();
        t2->stop();
    }catch(ThreadException ex) {
      printf("%s\n",ex.getMessage().c_str());
  } 
  delete t1;
  delete t2;
  return 0;

csrss wrote:

So how can i implement this? How to check if some line has been already read by some thread and another thread will not read it again?

// Defining a 'user defined' message for the call I wish to make
#define MYMESS_CALL_SOME_METHOD (WM_APP + 1)

struct ThreadParam
{
    HWND mDlg;    // Note: A handle.
};

UINT MyThreadProc( LPVOID pParam )
{
    ThreadParam* p = static_cast<ThreadParam*> (pParam);
    // Using message to call the method. Note: I could of course use the
    // WPARAM, LPARAM and returned value for something meaningful if I wished.
    ::SendMessage(p->mDlg, MYMESS_CALL_SOME_METHOD, 0, 0);
    delete p;
}

void CMyDialog::OnSomeButton()
{
     
    ThreadParam* param = new ThreadParam;
    param->mDlg = m_hWnd;  // A handle, not a dangerous 'this'
    AfxBeginThread(MyThreadProc, param);
    param = 0; // The other thread shall delete it    ...
}

//{{AFX_MSG(CMyDialog)
    ...
    afx_msg LRESULT OnCallSomeMethod(WPARAM, LPARAM);
    //}}AFX_MSG
    DECLARE_MESSAGE_MAP()

BEGIN_MESSAGE_MAP(CMyDialog, CDialog)
    //{{AFX_MSG_MAP(CMyDialog)
    ...
    ON_MESSAGE(MYMESS_CALL_SOME_METHOD, OnCallSomeMethod)
    //}}AFX_MSG_MAP
END_MESSAGE_MAP()

LRESULT CMyDialog::OnCallSomeMethod(WPARAM wp, LPARAM lp)
{
    callSomeMethod();
    return 0;
}

Michael Jansson wrote:

::SendMessage are thread safe!

Michael Jansson wrote:

SendMessage is thread-safe because can be called from multiple threads
without unwanted interaction between the threads

Michael Jansson wrote:

MFC is not thread safe.

glyfyx wrote:

Does anyone have an idea what's going on here?