Visual Servoing Platform version 3.5.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
54int thread_counter = 0;
55vpMutex mutex;
56
57vpThread::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
75int 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
93int 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 unlock()
Definition: vpMutex.h:111
void lock()
Definition: vpMutex.h:95
void * Return
Definition: vpThread.h:78
void *(* Fn)(Args)
Definition: vpThread.h:79
void * Args
Definition: vpThread.h:77
void create(vpThread::Fn fn, vpThread::Args args=NULL)
Definition: vpThread.h:110