【MQL5】CLExecute関数の使い方と自動売買実装コード

bool  CLExecute(
   int           kernel,           // CLContextCreateなどで作成したカーネルのハンドル
   uint          work_dim,         // ワークアイテムの次元数（1, 2, 3のいずれか）
   const uint&   work_offset[],    // 各次元の開始オフセット
   const uint&   work_size[],      // 各次元のワークアイテム数（実行する並列数）
   bool          wait=false        // 計算完了まで待機するかどうか（デフォルトはfalse）
);

//--- OpenCL用カーネルソース（文字列として定義）
const string cl_src = 
   "__kernel void VectorAdd(__global const float *a, __global const float *b, __global float *answer) "
   "{ "
   "   uint id = get_global_id(0); " // 自分のインデックス番号を取得
   "   answer[id] = a[id] + b[id]; "  // 並列で足し算を実行
   "} ";

void OnStart()
{
   int context, program, kernel;
   int buffer_a, buffer_b, buffer_answer;

   // 1. OpenCLコンテキストの作成（GPU優先）
   context = CLContextCreate(CL_USE_ANY);
   if(context == INVALID_HANDLE) { Print("OpenCL作成失敗"); return; }

   // 2. プログラムのビルドとカーネルの作成
   program = CLProgramCreate(context, cl_src);
   kernel = CLKernelCreate(program, "VectorAdd");

   // 3. データの準備（例：1000個のデータ）
   float a_data[], b_data[], ans_data[];
   uint data_size = 1000;
   ArrayResize(a_data, data_size);
   ArrayResize(b_data, data_size);
   ArrayResize(ans_data, data_size);
   for(uint i=0; i<data_size; i++) { a_data[i]=(float)i; b_data[i]=(float)i; }

   // 4. OpenCL用バッファの作成とデータ転送
   buffer_a = CLBufferCreate(context, data_size * sizeof(float), CL_MEM_READ_ONLY);
   buffer_b = CLBufferCreate(context, data_size * sizeof(float), CL_MEM_READ_ONLY);
   buffer_answer = CLBufferCreate(context, data_size * sizeof(float), CL_MEM_WRITE_ONLY);

   CLBufferWrite(buffer_a, a_data);
   CLBufferWrite(buffer_b, b_data);

   // 5. カーネルの引数をセット
   CLSetKernelArgMem(kernel, 0, buffer_a);
   CLSetKernelArgMem(kernel, 1, buffer_b);
   CLSetKernelArgMem(kernel, 2, buffer_answer);

   // 6. カーネルの実行
   uint work_size[1]; work_size[0] = data_size;
   uint work_offset[1]; work_offset[0] = 0;

   // CLExecuteの呼び出し
   if(!CLExecute(kernel, 1, work_offset, work_size, true))
   {
      Print("実行エラー: ", GetLastError());
   }

   // 7. 結果の読み取り
   CLBufferRead(buffer_answer, ans_data);
   Print("結果[999]: ", ans_data[999]); // 999+999=1998が出るはず

   // 8. リソースの解放
   CLBufferFree(buffer_a);
   CLBufferFree(buffer_b);
   CLBufferFree(buffer_answer);
   CLKernelFree(kernel);
   CLProgramFree(program);
   CLContextFree(context);
}