RunAsync

RunAsync()

RunAsync(UDFMethod function)

RunAsync(UDFMethod function, long timeOut)

<cfscript>
             //関数を非同期に実行して結果を取得する場合
             future = runAsync(function(){
                           return &quot;Hello World!&quot;;
                      });
             result = future;
             writeOutput(result.get());
</cfscript>

<cfscript>

// URL から応答を取得する関数を定義
function fetchResponseFromURL(url) {
    result = &quot;&quot;;
    httpService = new http(method = &quot;GET&quot;, charset = &quot;utf-8&quot;, url = url);
    httpService.addParam(name = &quot;q&quot;, type = &quot;url&quot;, value = &quot;cfml&quot;);
    result = httpService.send().getPrefix();
    writeDump(result);
    return result;
}

// 応答を取得したら、処理を実行（ここでは JSON を逆シリアル化するだけ）
future = runAsync(function(){
    return fetchResponseFromUrl(&quot;http://date.jsontest.com/&quot;);
    }).then( function(input){
        return deserializeJson(input.FileContent)
    });
    result = future.get()
    writedump(result);
</cfscript>

<cfscript>

// メールを送信する非同期関数を定義
function sendEmailAsync(toAddress, subject, body) {
    cfmail(to=toAddress, subject=subject, body=body, type=&quot;html&quot;);
}

// SMS を送信する非同期関数を定義
function sendSmsAsync(phoneNumber, message) {
    // 次の行を実際の SMS 送信ロジックに置き換え
    // 例：sendSmsFunction(phoneNumber, message);
}

// 実世界のようなデータを持つ受信者のリスト
recipients = [
    { email: &quot;recipient1@example.com&quot;, phone: &quot;1234567890&quot;, subject: &quot;Subject 1&quot;, body: &quot;Body 1&quot; },
    { email: &quot;recipient2@example.com&quot;, phone: &quot;0987654321&quot;, subject: &quot;Subject 2&quot;, body: &quot;Body 2&quot; },
    { email: &quot;recipient3@example.com&quot;, phone: &quot;5555555555&quot;, subject: &quot;Subject 3&quot;, body: &quot;Body 3&quot; },
    { email: &quot;recipient4@example.com&quot;, phone: &quot;6666666666&quot;, subject: &quot;Subject 4&quot;, body: &quot;Body 4&quot; },
    { email: &quot;recipient5@example.com&quot;, phone: &quot;7777777777&quot;, subject: &quot;Subject 5&quot;, body: &quot;Body 5&quot; },
    { email: &quot;recipient6@example.com&quot;, phone: &quot;8888888888&quot;, subject: &quot;Subject 6&quot;, body: &quot;Body 6&quot; },
    { email: &quot;recipient7@example.com&quot;, phone: &quot;9999999999&quot;, subject: &quot;Subject 7&quot;, body: &quot;Body 7&quot; },
    { email: &quot;recipient8@example.com&quot;, phone: &quot;1010101010&quot;, subject: &quot;Subject 8&quot;, body: &quot;Body 8&quot; },
    { email: &quot;recipient9@example.com&quot;, phone: &quot;2020202020&quot;, subject: &quot;Subject 9&quot;, body: &quot;Body 9&quot; },
    { email: &quot;recipient10@example.com&quot;, phone: &quot;3030303030&quot;, subject: &quot;Subject 10&quot;, body: &quot;Body 10&quot; }
];

// 受信者ごとにメール送信プロセスを非同期的に開始
for (var i = 1; i <= arrayLen(recipients); i++) {
    var recipient = recipients[i];
    runAsync(function() {
        sendEmailAsync(recipient.email, recipient.subject, recipient.body);
    });
}

// 受信者ごとに SMS 送信プロセスを非同期的に開始
for (var i = 1; i <= arrayLen(recipients); i++) {
    var recipient = recipients[i];
    runAsync(function() {
        sendSmsAsync(recipient.phone, &quot;SMS message content&quot;);
    });
}

// 次のコードはメールおよび SMS 送信プロセスの完了を待たずに直ちに実行される
writeOutput(&quot;メインスレッドでは...<br>&quot;);

</cfscript>

<cfscript>
             // タスク 1
             fibonacciTask = runAsync(function(){
                    // 最初の 10,000,000 個のフィボナッチ数列を生成
                   fib = [0, 1];
                    for (var i = 3; i < 10000000; i++) {
                        fib[i] = fib[i-1] + fib[i-2];
                    }
                    return fib;
              });
              // タスク 2
             matrixMultiplicationTask = runAsync(function(){

                    var matrix1 = [];
                    var matrix2 = [];
                    var result = [];

                    // ランダム行列を生成（簡単にするために、値が 1～10 の範囲にあると仮定）
                    for (var i = 1; i <= 200; i++) {
                        matrix1[i] = [];
                        matrix2[i] = [];
                        result[i] = [];
                        for (var j = 1; j <= 200; j++) {
                            matrix1[i][j] = randRange(1, 10);
                            matrix2[i][j] = randRange(1, 10);
                        }
                    }

                    // 行列を乗算
                    for (var i = 1; i <= 200; i++) {
                        for (var j = 1; j <= 200; j++) {
                            result[i][j] = 0;
                            for (var k = 1; k <= 200; k++) {
                                result[i][j] = result[i][j] + matrix1[i][k] * matrix2[k][j];
                            }
                        }
                    }
                    return result;
              });
              // タスク 3
             sleepingTask = runAsync(function(){
                    sleep(9000);
              });
             writedump(fibonacciTask.get());
             writedump(matrixMultiplicationTask.get());
             writedump(sleepingTask.get());

</cfscript>

<cfscript>

// 数値が素数であるかどうかを調べる関数
function isPrime(num) {
    if (num <= 1) return false;
    if (num <= 3) return true;

    if (num MOD 2 EQ 0 OR num MOD 3 EQ 0) return false;

    var i = 5;
    while (i * i <= num) {
        if (num MOD i EQ 0 OR num MOD (i + 2) EQ 0) return false;
        i = i + 6;
    }

    return true;
}

// 素数の合計を計算する関数
function calculatePrimeSum(start, end) {
    var sum = 0;
    for (var i = start; i <= end; i++) {
        if (isPrime(i)) {
            sum = sum + i;
        }
    }
    return sum;
}

// 素数計算の範囲を定義
startRange = 1;
endRange = 10000;

// 素数の合計を計算する複数の非同期タスクを並列に開始
task1Id = runAsync(function() {
    result1 = calculatePrimeSum(startRange, 2500);
    return result1;
});

task2Id = runAsync(function() {
    result2 = calculatePrimeSum(2501, 5000);
    return result2;
});

task3Id = runAsync(function() {
    result3 = calculatePrimeSum(5001, 7500);
    return result3;
});

task4Id = runAsync(function() {
    result4 = calculatePrimeSum(7501, endRange);
    return result4;
});

// 次のコードは非同期タスクの完了を待たずに直ちに実行される
    writeOutput(&quot;メインスレッドでは...<br>...<br>&quot;);
    writeDump(var=task1Id.get(), label=&quot;Task 1 ID&quot;);
    writeDump(var=task2Id.get(), label=&quot;Task 2 ID&quot;);
    writeDump(var=task3Id.get(), label=&quot;Task 3 ID&quot;);
    writeDump(var=task4Id.get(), label=&quot;Task 4 ID&quot;);
</cfscript>