customdb_samples/customdbsample_extended/mythreads.cpp

/* IBM Source Code */
/* (C) Copyright IBM Corp. 2009, 2012 */
/* Licensed Materials - Property of IBM */
/* US Government Users Restricted Rights - Use duplication or disclosure restricted by GSA Schedule Contract with IBM Corp. */
 
#include "dca/dca_base.h"
 
#include "perform_update_thread.h"
#include "schedule_thread.h"
 
using namespace dca;
 
void StartupThreads(const DcaInstance& aDcaInstance, const UpdateModule& aUpdateModule,
                                        volatile bool *schedulerErrorSignal, volatile bool *performUpdateErrorSignal)
{
        createPerformUpdateThread(aUpdateModule, performUpdateErrorSignal);
        createScheduleThread(aDcaInstance, schedulerErrorSignal);
}
 
void ShutdownThreads()
{
        shutdownScheduleThread();
        shutdownPerformUpdateThread();
}