- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
libcfa/src/concurrency/channel.hfa
r02c5880 r7a2c6b18 130 130 static inline void __cons_handoff( channel(T) & chan, T & elem ) with(chan) { 131 131 memcpy( cons`first.extra, (void *)&elem, sizeof(T) ); // do waiting consumer work 132 __atomic_thread_fence( __ATOMIC_SEQ_CST );133 132 wake_one( cons ); 134 133 } … … 137 136 static inline void __prods_handoff( channel(T) & chan, T & retval ) with(chan) { 138 137 memcpy( (void *)&retval, prods`first.extra, sizeof(T) ); 139 __atomic_thread_fence( __ATOMIC_SEQ_CST );140 138 wake_one( prods ); 141 139 }
Note:
See TracChangeset
for help on using the changeset viewer.