Atomic i atomowość operacji

Atomic i atomowość operacji
M1
  • Rejestracja:prawie 11 lat
  • Ostatnio:ponad 10 lat
  • Postów:7
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

Kopiuj
#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)

edytowany 1x, ostatnio: Mietek120
spartanPAGE
Kompilator? System?
M1
  • Rejestracja:prawie 11 lat
  • Ostatnio:ponad 10 lat
  • Postów:7
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.

Kopiuj
        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; }
 
M1
  • Rejestracja:prawie 11 lat
  • Ostatnio:ponad 10 lat
  • Postów:7
0

Ponawiam pytanie...

YU
  • Rejestracja:prawie 17 lat
  • Ostatnio:ponad 6 lat
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.


Azarien
  • Rejestracja:ponad 21 lat
  • Ostatnio:około 19 godzin
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ę?

lukasz1235
  • Rejestracja:ponad 17 lat
  • Ostatnio:ponad 8 lat
  • Postów:1105
0

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

M1
  • Rejestracja:prawie 11 lat
  • Ostatnio:ponad 10 lat
  • Postów:7
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.

Azarien
to to ja wiem.
DA
-pthread dodałeś?
M1
A po co pthread? W c++11 tego juz nie trzeba.
n0name_l
Mi to sie wydaje, ze @Azarien jednak umie skompilowac 10 linijek kodu -.-'. A post wyzej byl raczej odniesiem do chorego pomyslu w gcc kompilowania domyslnie zgodnie ze standardem z 03'.
Azarien
@n0name_l: mnie się to nie kompiluje nawet z -std=c++11. whatever, skoro "musi" działać to przeinstaluję mingwa.
Azarien
nic z tego. dalej nie działa. odpuszczam, bo nie mam na to czasu.
MarekR22
Moderator C/C++
  • Rejestracja:około 17 lat
  • Ostatnio:5 minut
0

Jeśli chcesz pomocy, NIE pisz na priva, ale zadaj dobre pytanie na forum.
edytowany 1x, ostatnio: MarekR22

Zarejestruj się i dołącz do największej społeczności programistów w Polsce.

Otrzymaj wsparcie, dziel się wiedzą i rozwijaj swoje umiejętności z najlepszymi.