Visual Servoing Platform  version 3.4.0
testMutex.cpp
1 /****************************************************************************
2  *
3  * ViSP, open source Visual Servoing Platform software.
4  * Copyright (C) 2005 - 2019 by Inria. All rights reserved.
5  *
6  * This software is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation; either version 2 of the License, or
9  * (at your option) any later version.
10  * See the file LICENSE.txt at the root directory of this source
11  * distribution for additional information about the GNU GPL.
12  *
13  * For using ViSP with software that can not be combined with the GNU
14  * GPL, please contact Inria about acquiring a ViSP Professional
15  * Edition License.
16  *
17  * See http://visp.inria.fr for more information.
18  *
19  * This software was developed at:
20  * Inria Rennes - Bretagne Atlantique
21  * Campus Universitaire de Beaulieu
22  * 35042 Rennes Cedex
23  * France
24  *
25  * If you have questions regarding the use of this file, please contact
26  * Inria at visp@inria.fr
27  *
28  * This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
29  * WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
30  *
31  * Description:
32  * Test threading capabilities.
33  *
34  * Authors:
35  * Fabien Spindler
36  *
37  *****************************************************************************/
38 
47 #include <iostream>
48 
49 #include <visp3/core/vpMutex.h>
50 #include <visp3/core/vpThread.h>
51 
52 #if defined(VISP_HAVE_PTHREAD) || (defined(_WIN32) && !defined(WINRT_8_0))
53 
54 int thread_counter = 0;
55 vpMutex mutex;
56 
57 vpThread::Return doSomeThing(vpThread::Args args)
58 {
59  mutex.lock();
60  unsigned int thread_id = *((unsigned int *)args);
61 
62  std::cout << "Started job " << thread_counter << " with id " << thread_id << std::endl;
63 
64  for (unsigned long i = 0; i < (0xFFFF); i++) {
65  };
66 
67  std::cout << "Ended job " << thread_counter << std::endl;
68 
69  thread_counter++;
70  mutex.unlock();
71 
72  return 0;
73 }
74 
75 int main(void)
76 {
77  unsigned int nthread = 10;
78  vpThread *thread = new vpThread[nthread];
79  unsigned int *thread_id = new unsigned int[nthread];
80 
81  for (unsigned int i = 0; i < nthread; i++) {
82  thread_id[i] = i;
83  thread[i].create((vpThread::Fn)&doSomeThing, (vpThread::Args)&thread_id[i]);
84  }
85 
86  delete[] thread;
87  delete[] thread_id;
88 
89  return 0;
90 }
91 
92 #else
93 int main()
94 {
95 #if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__))) // UNIX
96  std::cout << "You should enable pthread usage and rebuild ViSP..." << std::endl;
97 #else
98  std::cout << "Multi-threading seems not supported on this platform" << std::endl;
99 #endif
100 }
101 #endif
void lock()
Definition: vpMutex.h:95
void * Return
Definition: vpThread.h:78
void unlock()
Definition: vpMutex.h:111
void *(* Fn)(Args)
Definition: vpThread.h:79
void create(vpThread::Fn fn, vpThread::Args args=NULL)
Definition: vpThread.h:110
void * Args
Definition: vpThread.h:77