Implement wait handle to block a pJob until its all tasks (parallel subtasks and callback task) complete execution.

Oracle version simply utilizes the signaling mechanism which provided by SYS.DBMS_ALERT package;
At present, SQL Serverv version imitates it by a polling loop.

-- This version has not been tested yet.

Author: AbelCheng

TaskParallelFoundation/ConsoleTest/App.config

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="utf-8" ?>
 <configuration>
 	<connectionStrings>
-		<add name="TPW_Database" providerName="DDTek.Oracle" connectionString="TNSNames File=C:\Oracle\product\11.2.0\dbhome_1\NETWORK\ADMIN\tnsnames.ora;Data Source=ORADEV;Authentication Method=Client;Connection Timeout=600;Pooling=True;Min Pool Size=16;Max Pool Size=256;Max Pool Size Behavior=SoftCap;Initial Command Timeout=60;Application Name=TaskParallelPump"/>
+		<add name="TPW_Database" providerName="DDTek.Oracle" connectionString="TNSNames File=C:\Oracle\product\11.2.0\dbhome_1\NETWORK\ADMIN\tnsnames.ora;Data Source=ORCL;Authentication Method=Client;Connection Timeout=600;Pooling=True;Min Pool Size=16;Max Pool Size=256;Max Pool Size Behavior=SoftCap;Initial Command Timeout=60;Application Name=TaskParallelPump"/>
 		<!--<add name="TPW_Database" providerName="System.Data.SqlClient" connectionString="Data Source=.\SQLEXPRESS;AttachDbFilename=E:\Projects\DbParallel\TaskParallelFoundation\ConsoleTest\SampleDatabase\SqlServer\TaskParallelWorkflow.mdf;Integrated Security=True;User Instance=True"/>-->
 	</connectionStrings>
 	<appSettings>

TaskParallelFoundation/ConsoleTest/Program.cs

@@ -15,6 +15,7 @@ static void Main(string[] args)
 			PumpMain pump = new PumpMain();
 
 			pump.Start();
+			Console.WriteLine("The Pump Service is running ...");
 
 			Task.Factory.StartNew(() =>
 				{

TaskParallelFoundation/ConsoleTest/SampleDatabase/SqlServer/TaskParallelWorkflow.mdf

@@ -1,13 +1,11 @@
 using System;
-using System.Data.Common;
-using System.Configuration;
 using System.Data.SqlClient;
 
 namespace DbParallel.DataAccess.Booster.SqlServer
 {
 	public class SqlLauncher : DbLauncher
 	{
-		public SqlLauncher(DbProviderFactory dbProviderFactory, string connectionString, string destinationTableName, Action<SqlBulkCopyColumnMappingCollection> columnMappings = null,
+		public SqlLauncher(string connectionString, string destinationTableName, Action<SqlBulkCopyColumnMappingCollection> columnMappings = null,
 			int multipleRockets = _DefaultMultipleRockets, int bulkSize = _DefaultBulkSize, int commandTimeout = _CommandTimeout)
 		{
 			if (multipleRockets < _MinMultipleRockets)
@@ -17,42 +15,20 @@ public SqlLauncher(DbProviderFactory dbProviderFactory, string connectionString,
 				bulkSize = _MinBulkSize;
 
 			SqlConnection dbConnection;
-			SqlBulkCopy bulkCopy = CreateBulkCopy(dbProviderFactory, connectionString, out dbConnection, destinationTableName, columnMappings, commandTimeout);
+			SqlBulkCopy bulkCopy = CreateBulkCopy(connectionString, out dbConnection, destinationTableName, columnMappings, commandTimeout);
 			_FillingRocket = new SqlRocket(bulkCopy, dbConnection, bulkSize);
 
 			for (int i = 1; i < multipleRockets; i++)
 			{
-				bulkCopy = CreateBulkCopy(dbProviderFactory, connectionString, out dbConnection, destinationTableName, columnMappings, commandTimeout);
+				bulkCopy = CreateBulkCopy(connectionString, out dbConnection, destinationTableName, columnMappings, commandTimeout);
 				_FreeQueue.Add(new SqlRocket(bulkCopy, dbConnection, bulkSize));
 			}
 		}
 
-		public SqlLauncher(string providerName, string connectionString, string destinationTableName, Action<SqlBulkCopyColumnMappingCollection> columnMappings = null,
-			int multipleRockets = _DefaultMultipleRockets, int bulkSize = _DefaultBulkSize, int commandTimeout = _CommandTimeout)
-			: this(DbProviderFactories.GetFactory(providerName), connectionString,
-			destinationTableName, columnMappings, multipleRockets, bulkSize, commandTimeout)
-		{
-		}
-
-		public SqlLauncher(ConnectionStringSettings connSetting, string destinationTableName, Action<SqlBulkCopyColumnMappingCollection> columnMappings = null,
-			int multipleRockets = _DefaultMultipleRockets, int bulkSize = _DefaultBulkSize, int commandTimeout = _CommandTimeout)
-			: this(DbProviderFactories.GetFactory(connSetting.ProviderName), connSetting.ConnectionString,
-			destinationTableName, columnMappings, multipleRockets, bulkSize, commandTimeout)
-		{
-		}
-
-		public SqlLauncher(string connectionStringKey, string destinationTableName, Action<SqlBulkCopyColumnMappingCollection> columnMappings = null,
-			int multipleRockets = _DefaultMultipleRockets, int bulkSize = _DefaultBulkSize, int commandTimeout = _CommandTimeout)
-			: this(ConfigurationManager.ConnectionStrings[connectionStringKey],
-			destinationTableName, columnMappings, multipleRockets, bulkSize, commandTimeout)
-		{
-		}
-
-		private static SqlBulkCopy CreateBulkCopy(DbProviderFactory dbProviderFactory, string connectionString, out SqlConnection dbConnection,
+		private static SqlBulkCopy CreateBulkCopy(string connectionString, out SqlConnection dbConnection,
 			string destinationTableName, Action<SqlBulkCopyColumnMappingCollection> mapColumns, int commandTimeout)
 		{
-			dbConnection = dbProviderFactory.CreateConnection() as SqlConnection;
-			dbConnection.ConnectionString = connectionString;
+			dbConnection = new SqlConnection(connectionString);
 
 			SqlBulkCopy bulkCopy = new SqlBulkCopy(dbConnection);
 

TaskParallelFoundation/ConsoleTest/SampleDatabase/SqlServer/TaskParallelWorkflow_log.LDF

@@ -10,7 +10,7 @@ CREATE TABLE XYZ.TPW_PUMP_CONFIG
 	CONSTRAINT CK_TPW_PUMP_CONFIG_VALUE CHECK (NUMBER_VALUE IS NOT NULL OR DATE_VALUE IS NOT NULL OR STRING_VALUE IS NOT NULL)
 )
 ORGANIZATION INDEX
-STORAGE (INITIAL 16K NEXT 8K);
+STORAGE (INITIAL 16K NEXT 8K BUFFER_POOL KEEP);
 
 ----------------------------------------------------------------------------------------------------
 --

TaskParallelFoundation/DataAccess/SqlServer/Booster/SqlLauncher.cs

@@ -10,7 +10,7 @@ CREATE TABLE XYZ.TPW_WF_ACTIVITY
 	CONSTRAINT PK_TPW_WF_ACTIVITY PRIMARY KEY (ACTIVITY)
 )
 ORGANIZATION INDEX
-STORAGE (INITIAL 16K NEXT 8K);
+STORAGE (INITIAL 16K NEXT 8K BUFFER_POOL KEEP);
 
 ----------------------------------------------------------------------------------------------------
 --

TaskParallelFoundation/Databases/Oracle/Scripts/1-Tables/01-TPW_PUMP_CONFIG.sql

@@ -1,16 +1,18 @@
 -- CREATE TABLE
 CREATE TABLE XYZ.TPW_WF_STATE
 (
-	STATE_ID			NUMBER(5)		NOT NULL,
-	ACTIVITY			VARCHAR2(32)	NOT NULL,
-	STATE_NAME			VARCHAR2(32)	NOT NULL,
+	STATE_ID			NUMBER(5)					NOT NULL,
+	ACTIVITY			VARCHAR2(32)				NOT NULL,
+	STATE_NAME			VARCHAR2(32)				NOT NULL,
+	IS_DONE				NUMBER(1)		DEFAULT 0	NOT NULL,
 	DESCRIPTION_		VARCHAR2(256),
 	CONSTRAINT PK_TPW_WF_STATE PRIMARY KEY (STATE_ID),
 	CONSTRAINT UK_TPW_WF_STATE UNIQUE (ACTIVITY, STATE_NAME),
-	CONSTRAINT FK_TPW_WF_STATE_ACTIVITY FOREIGN KEY (ACTIVITY) REFERENCES XYZ.TPW_WF_ACTIVITY (ACTIVITY)
+	CONSTRAINT FK_TPW_WF_STATE_ACTIVITY FOREIGN KEY (ACTIVITY) REFERENCES XYZ.TPW_WF_ACTIVITY (ACTIVITY),
+	CONSTRAINT CK_TPW_WF_STATE_DONE CHECK (IS_DONE = 0 OR IS_DONE = 1)
 )
 ORGANIZATION INDEX
-STORAGE (INITIAL 64K NEXT 64K);
+STORAGE (INITIAL 64K NEXT 64K BUFFER_POOL KEEP);
 
 ----------------------------------------------------------------------------------------------------
 --

TaskParallelFoundation/Databases/Oracle/Scripts/1-Tables/03-TPW_WF_ACTIVITY.sql

@@ -10,7 +10,7 @@ CREATE TABLE XYZ.TPW_WF_EVENT
 	CONSTRAINT FK_TPW_WF_EVENT_ACTIVITY FOREIGN KEY (ACTIVITY) REFERENCES XYZ.TPW_WF_ACTIVITY (ACTIVITY)
 )
 ORGANIZATION INDEX
-STORAGE (INITIAL 32K NEXT 32K);
+STORAGE (INITIAL 32K NEXT 32K BUFFER_POOL KEEP);
 
 ----------------------------------------------------------------------------------------------------
 --

TaskParallelFoundation/Databases/Oracle/Scripts/1-Tables/04-TPW_WF_STATE.sql

@@ -21,7 +21,7 @@ CREATE TABLE XYZ.TPW_WF_STATE_MACHINE
 	CONSTRAINT FK_TPW_WF_STATE_MACHINE_EN FOREIGN KEY (ACTIVITY, EVENT_NAME) REFERENCES XYZ.TPW_WF_EVENT (ACTIVITY, EVENT_NAME),
 	CONSTRAINT FK_TPW_WF_STATE_MACHINE_SN1 FOREIGN KEY (ACTIVITY, STATE_NAME_NEW) REFERENCES XYZ.TPW_WF_STATE (ACTIVITY, STATE_NAME)
 )
-STORAGE (INITIAL 128K NEXT 128K);
+STORAGE (INITIAL 128K NEXT 128K BUFFER_POOL KEEP);
 
 CREATE UNIQUE INDEX XYZ.UK_TPW_WF_STATE_MACHINE_EV ON XYZ.TPW_WF_STATE_MACHINE (EVENT_ID, STATE_ID_OLD);