当前位置：网站首页>EA＆UML日拱一卒-多任务编程超入门-（9）线程同步

EA＆UML日拱一卒-多任务编程超入门-（9）线程同步

2022-07-29 23:42:00 【51CTO】

问题的提出

线程安全的数据类可以提供一种便利的手段来进行线程之间的数据交换，但是这种方法并没有协调两个线程的动作，这一点从输出结果也可以看出：

EA&UML日拱一卒-多任务编程超入门-（9）线程同步_数据操作

从输出可以看出，数据交换要么成功，要么就根本不能进行。这就是线程间没有同步的结果。解决这个问题就需要线程同步处理。

示例代码

本例中定义两个互斥量，dataReady和bufferReady。

       
       void WriteData(int i, 
       
               QMutex
       
       & dataReady, 
       
               QMutex
       
       & bufferReady)
       
{
       
    bufferReady.lock();
       
    cout 
       
       <
       
       < "WT:
       
       <
       
       <<
       
       <WriteData:" 
       
       <
       
       <
       
            i 
       
       <
       
       < "
       
       <
       
       <<
       
       <" 
       
       <
       
       < endl;
       
    int buffer[5];
       
    for(int j = 0; j 
       
       < 
       
       5; 
       
       ++j)
       
       {
       
       buffer[j] = 
       
       j;
       
       }
       
       data_array.setData(buffer, 
       
       5);
       
       dataReady.unlock();
       
       }
      
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.

WriteData方法首先尝试对bufferReady加锁，如果数据类中没有数据时，加锁操作成功，接下来按照正常逻辑写入数据，最后dataReady解锁，为ReadData创造执行条件。

       
       void ReadData(int i,  
       
             QMutex
       
       & dataReady,
       
             QMutex
       
       & bufferReady)
       
{
       
    dataReady.lock();
       
    cout 
       
       <
       
       < "RT:>>>>ReadData:" 
       
       <
       
       <
       
            i 
       
       <
       
       < ">>>>" 
       
       <
       
       < endl;
       
    int buffer[5];
       
    int data_size =
       
        data_array.removeData(buffer, 5);
       
    cout 
       
       <
       
       < "RT::----data_size=" 
       
       <
       
       <
       
            data_size 
       
       <
       
       < endl;
       
    int total = 0;
       
    for(int k = 0; k 
       
       < 
       
       data_size; 
       
       ++k)
       
       {
       
       total 
       
       += 
       
       buffer[k];
       
       }
       
       cout 
       
       << 
       
       "RT:----total="  
       
       <<
       
       total 
       
       << 
       
       endl;
       
       bufferReady.unlock();
       
       }
      
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.

ReadData方法首先尝试对dataReady加锁，如果数据类中存在数据时，加锁操作成功，接下来按照正常逻辑读出数据，最后对bufferReady解锁，为WriteData创造执行条件。

       
       int main(int /*argc*/, char*[] /*argv*/)
       
{
       
    //define CreateDataTask class.
       
    class CreateDataTask : public QThread
       
    {
       
        QMutex
       
       & m_data;
       
        QMutex
       
       & m_buffer;
       
    public:
       
        CreateDataTask(QMutex
       
       & dataReady, 
       
                       QMutex
       
       & bufferReady)
       
            :m_data(dataReady)
       
            ,m_buffer(bufferReady)
       
        {
       
        }
       
    private:
       
        void run()
       
        {
       
            for(int i = 0; i 
       
       < 
       
       10; 
       
       ++i)
       
       {
       
       WriteData(i, 
       
       m_data, 
       
       m_buffer);
       
       }
       
       }
       
       };
      
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.

       
       QMutex dataReady;
       
    QMutex bufferReady;
      
1.
2.

       
       ::timeBeginPeriod(1);
       
    dataReady.lock();
       
    //Create thread object of CreateDataTask.
       
    CreateDataTask *writer =
       
       new CreateDataTask(dataReady,  
       
                          bufferReady);
       
    //Start Thread.
       
    writer->start(QThread::NormalPriority);
       
    for(int i = 0; i 
       
       < 
       
       10; 
       
       ++i)
       
       {
       
       ReadData(i, 
       
       dataReady, 
       
       bufferReady);
       
       }
       
       timeEndPeriod(1);
       
       getch();    
       
       return 
       
       0;
       
       }
      
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.