class Example { public: unsigned m_value; Example() : m_value(0) {} unsigned GetValue() { return ++m_value; } unsigned GetSum() { unsigned sum = 0; #pragma omp parallel for for (ptrdiff_t i = 0; i < 100; i++) { #pragma omp atomic sum += GetValue(); } return sum; } };This example contains a race condition error and the value returned by it can vary every time the code is executed. If you try this example and the result is always correct you may change the function GetValue as shown below to make the error more transparent:
unsigned GetValue() { Sleep(0); m_value++; Sleep(0); return m_value; }In the code, "sum" variable is protected from increment with the atomic directive. But this directive does not influence the call of the function GetValue(). The calls occur in parallel threads and it leads to errors when executing "++m_value" operation inside the function GetValue.
Keep in mind that the functions used in the expressions to which atomic directive is applied, must be thread-safe. atomic directive deals with operations of the following types only:
- x binop= expr
- x++
- ++x
- x??
- ??x
In the example above, atomic directive protects "sum += " operation but not the call of the function GetValue. To correct the error mentioned you should use a critical section or other ways to protect m_value variable.
VivaMP tool included into PVS-Studio, will help you detect such errors. In this case, it diagnoses the error in the following way: Error V1205: Data race risk. Unprotected concurrent operation with the 'm_value' variable. What is important, the error can be detected at the early stage of writing the code, for VivaMP is a static code analyzer and does not require launching the application.
Комментариев нет:
Отправить комментарий