2016-07-31 4 views
3

У меня возникли проблемы с пониманием части поведения std :: atomic_short C++ 11.
Я установил либо 0, либо 255 как значение для переменной atomic_short.
Но .load() говорит, что значение не равно ни 0, ни 255.
Я хочу, чтобы один поток написал атомную переменную, и я хочу, чтобы другой поток прочитал его.Я не могу понять странное поведение std :: atomic_short.load()

Окружающая среда:
Intel Core i5
OSX 10.11.6
лязг (Xcode7.3.1)

#include <iostream> 
#include <atomic> 
#include <thread> 

std::atomic_short value = ATOMIC_VAR_INIT(0); 

void process1() { 
    bool flag = false; 
    for (int i = 0; i < 100000; ++i){ 
     std::this_thread::yield; 
     if (flag){ 
      value.store(255); 
     } else { 
      value.store(0); 
     } 
     flag = !flag; 
    } 
} 

void process2() { 
    for (int i = 0; i < 100000; ++i){ 
     std::this_thread::yield; 
     if (value.load() != 255 && value.load() != 0){ 
      printf("warningA! %d\n", i); 
     } 
    } 
} 

int main(int argc, char** argv) { 
    value.store(0); 
    std::thread t1(process1); 
    std::thread t2(process2); 
    t1.join(); 
    t2.join(); 

    return 0; 
} 

warningA! 3 
warningA! 1084 
warningA! 1093 

ответ

8

Проблема заключается в том, что у вас есть 2 отдельных load с, что делает ваше сравнение неатомное. Вместо этого load значение один раз, а затем сравните:

void process2() { 
    for (int i = 0; i < 100000; ++i){ 
     std::this_thread::yield; 
     auto currentValue = value.load(); 
     if (currentValue != 255 && currentValue != 0){ 
      printf("warningA! %d\n", i); 
     } 
    } 
} 

live example

Смежные вопросы