Changes in libcfa/src/concurrency/channel.hfa [7a2c6b18:02c5880]

File:

• libcfa/src/concurrency/channel.hfa (modified) (2 diffs)

libcfa/src/concurrency/channel.hfa

@@ -130 +130 @@
 static inline void __cons_handoff( channel(T) & chan, T & elem ) with(chan) {
     memcpy( cons`first.extra, (void *)&elem, sizeof(T) ); // do waiting consumer work
+    __atomic_thread_fence( __ATOMIC_SEQ_CST );
     wake_one( cons );
 }
@@ -136 +137 @@
 static inline void __prods_handoff( channel(T) & chan, T & retval ) with(chan) {
     memcpy( (void *)&retval, prods`first.extra, sizeof(T) );
+    __atomic_thread_fence( __ATOMIC_SEQ_CST );
     wake_one( prods );
 }