偽りの共有

#include <iostream> #include <thread> #include <new> #include <atomic> #include <chrono> #include <latch> #include <vector> 
 
 
 
 
 
 

名前空間std を使用します。名前空間chronoを使用します。  
  

#if defined(__cpp_lib_hardware_interference_size) 
// 実行時のデフォルトのキャッシュライン サイズ
constexpr size_t CL_SIZE = hardware_constructive_interference_size ; #else // 最も一般的なキャッシュライン サイズ、それ以外の場合はconstexpr size_t CL_SIZE = 64 ; #endif    


    


int main () { vector < jthread > threads ; int hc = jthread :: hardware_concurrency (); hc = hc <= CL_SIZE ? hc : CL_SIZE ; for ( int nThreads = 1 ; nThreads <= hc ; ++ nThreads ) { // スレッドの先頭をカーネル レベル ラッチで粗く同期coarseSync ( nThreads ) ; // ユーザー空間のアトミックを介して細かく同期atomic_uint fineSync ( nThreads ); // キャッシュラインに収まるだけの文字struct alignas ( CL_SIZE ) { char shareds [ CL_SIZE ]; } cacheLine ; // すべてのスレッドの実行時間の合計atomic_int64_t nsSum ( 0 ); for ( int t = 0 ; t != nThreads ; ++ t ) threads . emplace_back ( [ & ]( char volatile & c ) { coarseSync . arrive_and_wait (); // カーネルレベルでスレッド実行の開始を同期if ( fineSync . fetch_sub ( 1 , memory_order :: relaxed ) != 1 ) // ユーザーレベルでの細かい同期while ( fineSync . load ( memory_order :: relaxed ) ); auto start = high_resolution_clock :: now (); for ( size_t r = 10'000'000 ; r -- ; ) c = c + 1 ; nsSum += duration_cast < nanoseconds > ( 

     
       
            
             
    
        
           
        
           
        
              
        
           
                 
            
                    
                
                     
                            
                            
                       
                          
                            
                       high_resolution_clock :: now () - start ). count (); }, ref ( cacheLine . shareds [ t ] ) ); threads . resize ( 0 ); // すべてのスレッドを結合cout << nThreads << ": " << ( int )( nsSum / ( 1.0e7 * nThreads ) + 0.5 ) << endl ; } }