You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
147 lines
3.4 KiB
147 lines
3.4 KiB
/*
|
|
* Copyright 2002-2019 Intel Corporation.
|
|
*
|
|
* This software is provided to you as Sample Source Code as defined in the accompanying
|
|
* End User License Agreement for the Intel(R) Software Development Products ("Agreement")
|
|
* section 1.L.
|
|
*
|
|
* This software and the related documents are provided as is, with no express or implied
|
|
* warranties, other than those that are expressly stated in the License.
|
|
*/
|
|
|
|
// test-mt.cpp -- a simple multithreaded test program. I added markers to
|
|
// this to trigger the controller.
|
|
|
|
// g++ -o test-mt test-mt.cpp -lpthread
|
|
|
|
|
|
////////////////////////////////////////////////////////////////////////////
|
|
#include <cassert>
|
|
#include <string>
|
|
#include <stdio.h>
|
|
#include <iostream>
|
|
#include <ostream>
|
|
#include <iomanip>
|
|
#include <cstdlib>
|
|
#include <cctype>
|
|
|
|
#include<pthread.h>
|
|
using std::cout;
|
|
using std::endl;
|
|
////////////////////////////////////////////////////////////////////////////
|
|
// DEFINES
|
|
////////////////////////////////////////////////////////////////////////////
|
|
|
|
////////////////////////////////////////////////////////////////////////////
|
|
// TYPES
|
|
////////////////////////////////////////////////////////////////////////////
|
|
|
|
////////////////////////////////////////////////////////////////////////////
|
|
// PROTOTYPES
|
|
////////////////////////////////////////////////////////////////////////////
|
|
int main(int argc, char** argv, char** envp);
|
|
|
|
////////////////////////////////////////////////////////////////////////////
|
|
// GLOBALS
|
|
////////////////////////////////////////////////////////////////////////////
|
|
extern "C" {
|
|
// These functions are markers. The symbols are used to control tracing.
|
|
void marker_start_counting()
|
|
{
|
|
}
|
|
void marker_stop_counting()
|
|
{
|
|
}
|
|
|
|
void marker_emit_stats()
|
|
{
|
|
}
|
|
|
|
void marker_zero_stats()
|
|
{
|
|
}
|
|
}
|
|
|
|
class THREAD_STATE_T
|
|
{
|
|
int x;
|
|
public:
|
|
THREAD_STATE_T() {
|
|
}
|
|
};
|
|
|
|
pthread_mutex_t mutex;
|
|
|
|
void*
|
|
start_routine(void* arg)
|
|
{
|
|
int r;
|
|
|
|
marker_zero_stats();
|
|
marker_start_counting();
|
|
|
|
THREAD_STATE_T* thread_state = (THREAD_STATE_T*) arg;
|
|
r =pthread_mutex_lock(&mutex);
|
|
assert(r==0);
|
|
cout << "I'm in a thread!" << endl;
|
|
r =pthread_mutex_unlock(&mutex);
|
|
assert(r==0);
|
|
|
|
marker_emit_stats();
|
|
|
|
for(unsigned int i=0;i<50; i++)
|
|
{
|
|
marker_zero_stats();
|
|
marker_start_counting();
|
|
|
|
r =pthread_mutex_lock(&mutex);
|
|
assert(r==0);
|
|
r =pthread_mutex_unlock(&mutex);
|
|
|
|
marker_stop_counting();
|
|
marker_emit_stats();
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
int main(int argc, char** argv, char** envp)
|
|
{
|
|
pthread_attr_t attr;
|
|
int nthreads = (argc==2) ? atoi(argv[1]) : 4;
|
|
THREAD_STATE_T* thread_state = new THREAD_STATE_T[nthreads];
|
|
pthread_t* thread = new pthread_t[nthreads];
|
|
int r;
|
|
|
|
r = pthread_mutex_init(&mutex, 0);
|
|
assert(r==0);
|
|
|
|
r = pthread_attr_init(&attr);
|
|
assert(r==0);
|
|
|
|
for(int i=0;i<nthreads;i++)
|
|
{
|
|
r = pthread_create( thread+i,
|
|
&attr,
|
|
start_routine,
|
|
(void*) (thread_state+i) );
|
|
assert(r==0);
|
|
}
|
|
|
|
r = pthread_mutex_lock(&mutex);
|
|
assert(r==0);
|
|
cout << "I'm in the main thread!" << endl;
|
|
r = pthread_mutex_unlock(&mutex);
|
|
assert(r==0);
|
|
|
|
for(int i=0;i<nthreads;i++) {
|
|
r = pthread_join(thread[i], 0);
|
|
assert(r==0);
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
|
|
////////////////////////////////////////////////////////////////////////////
|