Atomic i atomowość operacji

2

Witam
Mam taki problem, próbuję się poduczyć używania atomic'ow w C++. Skonstruowałem sobie programik, który w zamierzeniu miał pokazać natychmiast, że atomowość atomiców jest faktycznie prawdą.
Na początku tworzę zmienną int (ustawioną na 0), potem tworzę dwa wątki, które będą tą zmienną modyfikować używając operatora post-inkrementacji. Po zakończeniu obu wątków zmienna powinna mieć wartość 2. Oczywiście użycie zwykłej zmiennej int prowadzi do tego, ze za którymś dojdzie do sytuacji wyścigu i wartość zmiennej zostanie nadpisana przez drugi wątek bez uwzględnienia wcześniejszej zmiany, przez co po zakończeniu działania przez oba wątki zmienna będzie mieć wartość inną niż 2.

Myślałem, że po zmianie typu zmiennej ze zwykłej int na atomic<int> sytuacja natychmiast się poprawi. Jakież było moje zdziwienie, gdy zobaczyłem, że za którymś razem również zmienna nie jest równa 2 po zakończeniu pracy obu wątków.

Czy ktoś może mi wyjaśnić gdzie leży błąd? Czego nie rozumiem w kwestii atomic'ów? Dokumentacja twierdzi, że operator post-inkrementacji działa atomowo.

Będę wdzięczny za pomoc. Poniżej wklejam kod.
Pozdrawiam
Mietek

#include <iostream>
#include <thread>
#include <atomic>
using namespace std;

int main()
{
    for(int i = 0; i < 1000000; i++){
        atomic<int> a(0);
        //int a = 0;
        thread t1([&a]{ a++; });
        thread t2([&a]{ a++; });

        t1.join();
        t2.join();
        if(a != 2) { cout << "error: " << a << ", i = " << i << endl; break; }
    }
    return 0;
}
 

Używam MinGW (GCC) 4.8.1 na Windows (CodeBlocks 13.12)

C:\Program Files (x86)\CodeBlocks\MinGW\bin>"mingw32-c++.exe" -v
Using built-in specs.
COLLECT_GCC=mingw32-c++.exe
COLLECT_LTO_WRAPPER=c:/program\ files\ (x86)/codeblocks/mingw/bin/../libexec/gcc/mingw32/4.8.1/lto-wrapper.exe
Target: mingw32
Configured with: ../../../src/gcc-4.8.1/configure --build=mingw32 --enable-languages=ada,c,c++,fortran,lto,objc,obj-c++ --enable-libgomp --enable-lto --enable-graphite --
x-debug --enable-threads=posix --enable-version-specific-runtime-libs --enable-fully-dynamic-string --enable-libstdcxx-threads --enable-libstdcxx-time --with-gnu-ld --dis
isable-nls --disable-win32-registry --disable-symvers --enable-cxx-flags='-fno-function-sections -fno-data-sections -DWINPTHREAD_STATIC' --prefix=/mingw32tdm --with-local
2tdm --with-pkgversion=tdm-2 --enable-sjlj-exceptions --with-bugurl=http://tdm-gcc.tdragon.net/bugs
Thread model: posix
gcc version 4.8.1 (tdm-2)

0

Mały update:

Ciekawe jest to, że jak zmienię powyższy kod na ten poniżej, to wszystko działa poprawnie i atomic'i pokazują, że naprawdę są atomowe (w przeciwienstwie do zwyklej zmiennej int). Dlaczego jednak nie dzieje się tak w kodzie powyżej? Tego wciąż nie wiem.

        atomic<int> a(0);
        //int a = 0;

        auto fun = [&a]{ for(int i = 0; i < 100000000; i++) ++a; };
        thread t1(fun);
        thread t2(fun);

        t1.join();
        t2.join();
        if(a != 200000000) { cout << "error: " << a << endl; }
 
0

Ponawiam pytanie...

0

Kod wydaje sie byc OK, wskazowka moga byc te watki:

http://4programmers.net/Forum/C_i_C++/224448-brak_rozumienia_stdthread_i_lambdy_czy_bugi_mingw?p=986525#id986525
http://4programmers.net/Forum/Newbie/151770-nie_dziala_stdthread_w_code_blocks

Wynika z nich ze std::thread pod mingw 4.8 jest zbugowane. Jesli tylko masz taka mozliwosc, sprawdz kod pod msvc/linuksem.

0

Mnie się ten kod pod MinGW (GCC 4.8.1) w ogóle nie kompiluje (error: 'thread' was not declared in this scope). hę?

0

Linux, GCC 4.9.1
Wygląda na to, że wszystko działa poprawnie.

0
Azarien napisał(a):

Mnie się ten kod pod MinGW (GCC 4.8.1) w ogóle nie kompiluje (error: 'thread' was not declared in this scope). hę?

Musisz wlaczyc w opcjach C++11.

1 użytkowników online, w tym zalogowanych: 0, gości: 1