The TaskScheduler_Action_PHPScript class is pretty much an example.
1. Decide your action name. e.g. task_scheduler_action_remote_database_updater.
2. Create an action class extending the TaskScheduler_Action_Base class.
3. Create a thread class extending the TaskScheduler_Action_Base class.
4. In the doAction() method of the action class defined in the above step 2, create a thread by calling TaskScheduler_ThreadUtility::derive().
5. In the doAction() method of the thread class defined in the above step 3, do actual database updates.
6. In the construct() method of the action class, instantiate the thread class passing the action name, made up in the step 1.
To pass a function name to a thread, set a function name in the $_aThreadOptions array like $_aThreadOptions[ 'func_name' ] then in the doAction() of the thread class, you get options with $_aThreadOptions = $oRoutine->getMeta(); the object $oRoutine is passed with the second parameter of the doAction() method. Then you can call your function with call_user_func_array();
I would do something like this.
class YourTaskAction extends TaskScheduler_Action_Base {
public function construct() {
new YourThreadActionClass( 'task_scheduler_action_remote_database_updater' );
}
public function getLabel( $sLabel ) {
return 'My Task Action Name';
}
public function getDescription( $sDescription ) {
return 'Here is my description.';
}
public function doAction( $isExitCode, $oRoutine ) {
$_aTaskMeta = $oRoutine->getMeta();
if ( ! isset( $_aTaskMeta[ $this->sSlug ] ) ) {
return 0; // failed
}
// Handle each database row per thread
$_aRows = $this->___getRows();
$_iThreads = 0;
$_iCount = 0;
foreach( $_aRows as $_aRow ) {
$_iCount++;
$_aThreadOptions = array(
// Required
'routine_action' => 'task_scheduler_action_remote_database_updater',
'post_title' => sprintf( __( 'Thread %1$s of %2$s', 'task-scheduler' ), $_iCount + 1, $oRoutine->post_title ),
'parent_routine_log_id' => $oRoutine->log_id, // the log_id key is set when a routine starts
// internal options
'_next_run_time' => microtime( true ),
// Routine specific options
'func_name' => 'my_func_name',
'func_params' => $_aRow,
);
$_iThreadTaskID = TaskScheduler_ThreadUtility::derive( $oRoutine->ID, $_aThreadOptions );
$_iThreads = $_iThreadTaskID ? ++$_iThreads : $_iThreads;
}
// Check actions in the background.
if ( $_iThreads ) {
do_action( 'task_scheduler_action_check_scheduled_actions' );
}
return null; // exit code: do not log; it will be, when the threads finish.
}
/**
* Retrieve database rows.
* @return array
*/
private function ___getRows() {
return array();
}
}
class YourThreadActionClass extends TaskScheduler_Action_Base {
public function getLabel( $sLabel ) {
return 'Remote Database Updater';
}
/**
* Do you stuff
*/
public function doAction( $isExitCode, $oThread ) {
$_aThreadMeta = $oThread->getMeta();
return call_user_func_array( $_aThreadMeta[ 'func_name' ], $_aThreadMeta[ 'func_params' ] );
}
}
In the ___getRows() function, it is returning an array but in your actual code, you are supposed to retrieve database rows. Modify the code as you need.
