Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/test__mt_8cpp_source.html below:

NCBI C++ ToolKit: src/corelib/test_mt.cpp Source File

<< #expr << ") --- " << msg << endl; \

(

);

RunNative(

);

JoinNative(

**

);

<<

);

<< num);

<<

);

<<

);

thread_obj->

();

NativeWrapper(arg);

NativeWrapper(arg);

CTestThread::RunNative(

)

creation_flags = 0;

, creation_flags, &thread_id);

0,

, DUPLICATE_SAME_ACCESS),

);

);

);

NativeWrapperCaller,

) == 0,

);

);

(0,

);

CTestThread::JoinNative(

**

)

);

&& status !=

(STILL_ACTIVE),

);

);

);

(

= first_idx;

< first_idx + spawn_max;

++) {

[

]->RunNative();

*

(

);

number_of_threads,

has_sync_point);

number_of_threads,

: m_Number_of_threads(number_of_threads), m_Has_sync_point(has_sync_point),

m_Semaphore(0,number_of_threads), m_SyncCounter(0)

reached =

;

<< num);

arg_desc->AddDefaultKey

(

,

,

,

arg_desc->SetConstraint

arg_desc->AddDefaultKey

(

,

,

,

arg_desc->SetConstraint

arg_desc->AddDefaultKey

(

,

,

,

arg_desc->SetConstraint

arg_desc->AddOptionalKey(

,

,

,

arg_desc->SetUsageContext(

().GetProgramBasename(),

);

(!args[

].AsInteger()) {

= args[

].AsInteger();

);

?

(

()[

].AsInteger())

threshold =

(TEST_MT, Cascading)::GetDefault();

(threshold > 100) {

(

);

cascading = (

(rand() % 100)) < threshold;

<<

<<

);

[

]->JoinNative(&join_result);

<<

<<

);

[

]->Join(&join_result);

<<

<<

);

(

= 0;

[

]->Join(&join_result);

<<

<<

);

<<

.

());

);

(

);

threshold =

(threshold > 100) {

(

);

(

= 0;

<

; ++

) {

group.has_sync_point = ((

)(rand() % 100)) < threshold;

group.number_of_threads = 1;

(

= 0;

< threads_left; ++

) {

(

= 0;

<

; ++

) {

start_now =

;

dest = rand() % (

+1);

os <<

<< (

- start_now)

<<

<< start_now;

[idx]->SyncPoint();

);

[idx]->GlobalSyncPoint();

num_min,

num_max)

CInGroupThread(CThreadGroup &group, int id)

virtual void SyncPoint(void)

virtual void * Main(void)

Derived (user-created) class must provide a real thread function.

CNcbiOstrstreamToString class helps convert CNcbiOstrstream to a string Sample usage:

virtual void * Main(void)

Derived (user-created) class must provide a real thread function.

virtual void GlobalSyncPoint(void)

virtual void * Main(void)

Derived (user-created) class must provide a real thread function.

CTestThread(CSeqDBAtlas &atlas)

static void StartCascadingThreads(void)

virtual void SyncPoint(void)

virtual void OnExit(void)

Override this to execute finalization code.

unsigned int m_Number_of_threads

unsigned int m_SyncCounter

CThreadGroup(unsigned int number_of_threads, bool has_sync_point)

void ThreadComplete(void)

iterator_bool insert(const value_type &val)

const_iterator find(const key_type &key) const

const_iterator end() const

virtual const CArgs & GetArgs(void) const

Get parsed command line arguments.

virtual void SetupArgDescriptions(CArgDescriptions *arg_desc)

Setup the command line argument descriptions.

const CNcbiArguments & GetArguments(void) const

Get the application's cached unprocessed command-line arguments.

@ eInteger

Convertible into an integer number (int or Int8)

void Set(TValue new_value) THROWS_NONE

Set atomic counter value.

TValue Add(int delta) THROWS_NONE

Atomically add value (=delta), and return new counter value.

TValue Get(void) const THROWS_NONE

Get atomic counter value.

#define ERR_FATAL(message)

Posting fatal error and abort.

const unsigned int k_NumThreadsMin

Minimum number of threads.

vector< SThreadGroup > m_ThreadGroups

const unsigned int k_NumThreadsMax

Maximum number of threads.

unsigned int x_InitializeDelayedStart(void)

CThreadedApp(void)

Constructor.

virtual bool TestApp_Exit(void)

Override this method to execute code after all threads terminate.

unsigned int m_LogMsgCount

const int k_SpawnByMax

Maximum number of spawn by threads.

void SetNumberOfDelayedStartSyncPoints(unsigned int num_min, unsigned int num_max)

Set allowed range of delayed-start sync points.

~CThreadedApp(void)

Destructor.

virtual bool Thread_Run(int idx)

Run the thread.

int Run(void)

Run the threads.

virtual bool Thread_Destroy(int idx)

Destroy the thread.

void Init(void)

Initialize the app.

unsigned int s_NumThreads

atomic< unsigned int > m_NextGroup

virtual bool Thread_Init(int idx)

Initialize the thread.

const int k_SpawnByMin

Minimum number of spawn by threads.

virtual bool Thread_Exit(int idx)

Exit the thread.

void TestApp_IntraGroupSyncPoint(void)

Wait until other threads in group reach the same sync point The call may be ignored by the applicatio...

void x_PrintThreadGroups(void)

virtual bool TestApp_Init(void)

Override this method to execute code before running threads.

void TestApp_GlobalSyncPoint(void)

Wait until ALL threads reach a call of TestApp_GlobalSyncPoint().

void x_InitializeThreadGroups(void)

vector< unsigned int > m_Delayed

void TestApp_DelayedStartSyncPoint(const string &name)

Start threads that belong to delayed group (this call may be ignored to provide more randomness).

void x_StartThreadGroup(unsigned int count)

virtual bool TestApp_Args(CArgDescriptions &args)

Override this method to add your custom arguments.

#define NCBI_PARAM_TYPE(section, name)

Generate typename for a parameter from its {section, name} attributes.

#define END_NCBI_SCOPE

End previously defined NCBI scope.

#define BEGIN_NCBI_SCOPE

Define ncbi namespace.

static string SizetToString(size_t value, TNumToStringFlags flags=0, int base=10)

Convert size_t to string.

static string IntToString(int value, TNumToStringFlags flags=0, int base=10)

Convert int to string.

static string UIntToString(unsigned int value, TNumToStringFlags flags=0, int base=10)

Convert UInt to string.

static unsigned int StringToUInt(const CTempString str, TStringToNumFlags flags=0, int base=10)

Convert string to unsigned int.

static unsigned int GetRandomSeed(void)

Return a seed to use with srand() function to randomize new sequence of pseudo-random integers return...

void * TWrapperArg

Define platform-dependent argument wrapper.

TThreadHandle m_Handle

platform-dependent thread handle

void Lock(void)

Acquire mutex for the current thread with no nesting checks.

pthread_t TThreadHandle

Define platform-dependent thread handle type.

void Wait(void)

Wait on semaphore.

static void InitializeMainThreadId(void)

Initialize main thread's TID.

static TWrapperRes Wrapper(TWrapperArg arg)

Function to use (internally) as the thread's startup function.

void * TWrapperRes

Define platform-dependent result wrapper.

void Post(unsigned int count=1)

Increment the semaphore by "count".

void Unlock(void)

Release mutex with no owner or nesting checks.

@ fRunAllowST

Allow threads to run in single thread builds.

#define HANDLE

An abstraction for a file handle.

unsigned int

A callback function used to compare two keys in a database.

#define FALSE

bool replacment for C indicating false.

void SleepMilliSec(unsigned long ml_sec, EInterruptOnSignal onsignal=eRestartOnSignal)

NCBI tests specific functions.

Multi-threading – mutexes; rw-locks; semaphore.

TWrapperRes(* FSystemWrapper)(TWrapperArg)

Thread group description parameters.

static CMiniMutex s_GlobalLock

static string s_GroupsCount(void)

NCBI_PARAM_DEF(unsigned int, TEST_MT, Cascading, 25)

DEFINE_STATIC_FAST_MUTEX(s_GlobalLock)

static CThreadedApp * s_Application

CRef< CTestThread > thr[k_NumThreadsMax]

static CAtomicCounter s_SyncCounter

static atomic< unsigned int > s_NextIndex

NCBI_PARAM_DECL(unsigned int, TEST_MT, Cascading)

NCBI_PARAM_DEF_WITH_INIT(string, TEST_MT, GroupsCount, "", s_GroupsCount)

#define TESTAPP_LOG_POST(x)

static CSemaphore s_Semaphore(0, INT_MAX)

#define TESTAPP_ASSERT(expr, msg)

static CAtomicCounter s_NumberOfThreads

static CStaticTls< int > s_ThreadIdxTLS

static CRef< CThreadGroup > thr_group[k_NumThreadsMax]

Wrapper for testing modules in MT environment.

int g(Seg_Gsm *spe, Seq_Mtf *psm, Thd_Gsm *tdg)

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4