DependentTransaction による同時実行の管理

[アーティクル]
09/17/2008

Transaction オブジェクトは、DependentClone メソッドを使用して作成されます。このオブジェクトの唯一の目的は、他のコード (ワーカースレッドなど) でトランザクションの処理を実行している間、トランザクションをコミットできないように保証することです。複製されたトランザクション内の処理が完了してコミットの準備が整うと、Complete メソッドを使用して、そのトランザクションの作成者に通知できます。これにより、データの一貫性と正確性を保持できます。

DependentTransaction クラスは、非同期タスク間の同時実行の管理にも使用できます。この場合は、トランザクションに依存している複製が独自のタスクの処理を行う間、親が任意のコードの実行を継続できます。つまり、依存している複製が完了するまで親の実行がブロックされることはありません。

トランザクションに依存している複製の作成

依存トランザクションを作成するには、DependentClone メソッドを呼び出し、パラメータとして DependentCloneOption 列挙体を渡します。このパラメータは、トランザクションに依存している複製が Complete メソッドを呼び出してトランザクションのコミットの準備が整ったことを示す前に、親トランザクションで Commit が呼び出された場合のトランザクションの動作を定義します。このパラメータで有効な値は次のとおりです。

BlockCommitUntilComplete は、親トランザクションがタイムアウトするまで、またはすべての依存トランザクションで完了を示す Complete が呼び出されるまで、親トランザクションのコミットプロセスをブロックする依存トランザクションを作成します。これは、依存トランザクションが完了するまで、クライアントが親トランザクションのコミットを望まない場合に役立ちます。親トランザクションが依存トランザクションより前に処理を完了して Commit を呼び出した場合、すべての依存トランザクションが Complete を呼び出すまで、コミットプロセスはブロックされ、そのトランザクションで追加処理を実行し、新しい参加リストを作成できる状態になります。すべての依存トランザクションの処理が完了し、Complete を呼び出すとすぐに、トランザクションのコミットプロセスが開始します。
一方、RollbackIfNotCompleteでは、Complete が呼び出される前に親トランザクションで Commit が呼び出された場合、自動的に中止する依存トランザクションが作成されます。この場合、依存トランザクションで行われたすべての処理は、1 つのトランザクションの有効期間内はそのまま変更されず、その一部でもコミットすることはできません。

アプリケーションが依存トランザクションでその処理を完了した場合、Complete メソッドを 1 回だけ呼び出す必要があります。それ以外の場合は、InvalidOperationException がスローされます。この呼び出しを行った後は、トランザクションで追加作業を行わないでください。例外が発生します。

次のコード例では、依存トランザクションの複製を作成してワーカースレッドに渡すことにより、2 つの同時実行タスクを管理する依存トランザクションを作成する方法を示しています。

public class WorkerThread
{
    public void DoWork(DependentTransaction dependentTransaction)
    {
        Thread thread = new Thread(ThreadMethod);
        thread.Start(dependentTransaction); 
    }

    public void ThreadMethod(object transaction) 
    { 
        DependentTransaction dependentTransaction = transaction as DependentTransaction;
        Debug.Assert(dependentTransaction != null); 
        try
        {
            using(TransactionScope ts = new TransactionScope(dependentTransaction))
            {
                /* Perform transactional work here */ 
                ts.Complete();
            }
        }
        finally
        {
            dependentTransaction.Complete(); 
             dependentTransaction.Dispose(); 
        }
    }

//Client code 
using(TransactionScope scope = new TransactionScope())
{
    Transaction currentTransaction = Transaction.Current;
    DependentTransaction dependentTransaction;    
    dependentTransaction = currentTransaction.DependentClone(DependentCloneOption.BlockCommitUntilComplete);
    WorkerThread workerThread = new WorkerThread();
    workerThread.DoWork(dependentTransaction);
    /* Do some transactional work here, then: */
    scope.Complete();
}

このクライアントコードは、アンビエントトランザクションの設定も行うトランザクションスコープを作成します。アンビエントトランザクションをワーカースレッドに渡さないでください。その代わりに、現在のトランザクションで DependentClone メソッドを呼び出すことにより、現在の (アンビエント) トランザクションを複製し、依存トランザクションをワーカースレッドに渡す必要があります。

ThreadMethod メソッドは、新しいスレッドで実行されます。クライアントは新しいスレッドを開始し、ThreadMethod パラメータとして依存トランザクションを渡します。

依存トランザクションは BlockCommitUntilComplete により作成されるため、2 番目のスレッド上ですべてのトランザクションの処理が完了し、依存トランザクションで Complete が呼び出されるまで、トランザクションがコミットされないことが保証されます。つまり、新しいスレッドが依存トランザクションで Complete を呼び出す前にクライアントのスコープが終了した場合 (using ステートメントの最後でトランザクションオブジェクトの破棄を試みた場合)、依存トランザクションで Complete が呼び出されるまで、クライアントコードはブロックします。その後、トランザクションはコミットまたは中止の処理を完了できます。

同時実行に関する問題

同時実行に関して、DependentTransaction クラスを使用する場合に注意が必要な問題がいくつかあります。

ワーカースレッドがトランザクションをロールバックし、親がトランザクションのコミットを試みた場合、TransactionAbortedException がスローされます。
トランザクション内の各ワーカースレッドについて、トランザクションに依存している複製を新しく作成する必要があります。同一の依存している複製を複数のスレッドに渡さないでください。その複製に対して Complete を呼び出すことができるのは、1 つのスレッドのみであるためです。
ワーカースレッドが新しいワーカースレッドを生成する場合、依存している複製から依存している複製を作成し、それを新しいスレッドに渡してください。

DependentTransaction による同時実行の管理

トランザクションに依存している複製の作成

同時実行に関する問題

関連項目

参照

その他のリソース