163 lines
3.6 KiB
C++
163 lines
3.6 KiB
C++
/*
|
|
* Copyright information and license terms for this software can be
|
|
* found in the file LICENSE that is included with the distribution
|
|
*/
|
|
/*
|
|
* testThread.cpp
|
|
*
|
|
* Created on: 2010.11
|
|
* Author: Marty Kraimer
|
|
*/
|
|
|
|
#include <cstddef>
|
|
#include <cstdlib>
|
|
#include <cstddef>
|
|
#include <string>
|
|
#include <cstdio>
|
|
#include <cstring>
|
|
#include <list>
|
|
|
|
#include <epicsUnitTest.h>
|
|
#include <testMain.h>
|
|
|
|
|
|
#include <pv/event.h>
|
|
#include <pv/thread.h>
|
|
|
|
using namespace epics::pvData;
|
|
using std::string;
|
|
|
|
static string actionName("action");
|
|
|
|
class Action;
|
|
typedef std::tr1::shared_ptr<Action> ActionPtr;
|
|
|
|
class Action : public Runnable {
|
|
public:
|
|
virtual ~Action() {}
|
|
FILE *out;
|
|
bool actuallyRan;
|
|
Event begin, end;
|
|
Action(): actuallyRan(false) {}
|
|
virtual void run() {
|
|
testDiag("Action waiting");
|
|
begin.signal();
|
|
bool waited=end.wait();
|
|
actuallyRan=true;
|
|
testDiag("Action %s", waited?"true":"false");
|
|
}
|
|
};
|
|
|
|
static void testThreadRun() {
|
|
// show that we can control thread start and stop
|
|
ActionPtr ax(new Action());
|
|
{
|
|
epics::pvData::ThreadPtr tr(new epics::pvData::Thread(actionName,lowPriority,ax.get()));
|
|
bool w=ax->begin.wait();
|
|
testDiag( "main %s", w?"true":"false");
|
|
testDiag( "Action is %s", ax->actuallyRan?"true":"false");
|
|
ax->end.signal();
|
|
}
|
|
testOk1(ax->actuallyRan==true);
|
|
testDiag( "Action is %s", ax->actuallyRan?"true":"false");
|
|
testDiag("testThreadRun PASSED");
|
|
}
|
|
|
|
namespace {
|
|
struct fninfo {
|
|
int cnt;
|
|
epicsEvent evnt;
|
|
};
|
|
|
|
static void threadFN(void *raw)
|
|
{
|
|
fninfo *arg = (fninfo*)raw;
|
|
arg->evnt.signal();
|
|
arg->cnt++;
|
|
}
|
|
|
|
struct classMeth {
|
|
int cnt;
|
|
epicsEvent evnt;
|
|
classMeth() :cnt(0) {}
|
|
void inc() {
|
|
const char *tname = epicsThreadGetNameSelf();
|
|
testOk(strcmp(tname, "test2")==0, "thread name '%s' == 'test2' ", tname);
|
|
evnt.signal();
|
|
cnt++;
|
|
}
|
|
};
|
|
}
|
|
|
|
static void testBinders()
|
|
{
|
|
testDiag("Testing thread bindables");
|
|
|
|
testDiag("C style function");
|
|
{
|
|
fninfo info;
|
|
info.cnt = 0;
|
|
epics::pvData::Thread foo(epics::pvData::Thread::Config(&threadFN, (void*)&info)
|
|
.name("test1")
|
|
.prio(epicsThreadPriorityMedium)
|
|
.autostart(true)
|
|
);
|
|
|
|
info.evnt.wait();
|
|
|
|
foo.exitWait();
|
|
|
|
testOk(info.cnt==1, "cnt (%d) == 1", info.cnt);
|
|
}
|
|
|
|
testDiag("class method");
|
|
{
|
|
classMeth inst;
|
|
|
|
epics::pvData::Thread foo(epics::pvData::Thread::Config(&inst, &classMeth::inc)
|
|
.prio(epicsThreadPriorityMedium)
|
|
.autostart(false)
|
|
<<"test"<<2
|
|
);
|
|
|
|
epicsThreadSleep(0.1);
|
|
|
|
testOk(inst.cnt==0, "inst.cnt (%d) == 0", inst.cnt);
|
|
|
|
foo.start();
|
|
inst.evnt.wait();
|
|
foo.exitWait();
|
|
|
|
testOk(inst.cnt==1, "inst.cnt (%d) == 1", inst.cnt);
|
|
}
|
|
|
|
testDiag("C++11 style lambda");
|
|
#if __cplusplus>=201103L
|
|
{
|
|
int cnt = 0;
|
|
epicsEvent evnt;
|
|
auto fn = [&cnt,&evnt]() mutable {evnt.signal(); cnt++;};
|
|
epics::pvData::Thread foo(epics::pvData::Thread::Config(fn)
|
|
.name("test3")
|
|
.prio(epicsThreadPriorityMedium)
|
|
.autostart(true)
|
|
);
|
|
evnt.wait();
|
|
foo.exitWait();
|
|
|
|
testOk(cnt==1, "cnt (%d) == 1", cnt);
|
|
}
|
|
#else
|
|
testSkip(1, "Not built as C++11");
|
|
#endif
|
|
}
|
|
|
|
MAIN(testThread)
|
|
{
|
|
testPlan(6);
|
|
testDiag("Tests thread");
|
|
testThreadRun();
|
|
testBinders();
|
|
return testDone();
|
|
}
|