Visual Servoing Platform version 3.6.0
Loading...
Searching...
No Matches
testMutex.cpp
1/****************************************************************************
2 *
3 * ViSP, open source Visual Servoing Platform software.
4 * Copyright (C) 2005 - 2023 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 https://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*****************************************************************************/
35
44#include <iostream>
45
46#include <visp3/core/vpMutex.h>
47#include <visp3/core/vpThread.h>
48
49#if defined(VISP_HAVE_PTHREAD) || (defined(_WIN32) && !defined(WINRT_8_0))
50
51int thread_counter = 0;
52vpMutex mutex;
53
54vpThread::Return doSomeThing(vpThread::Args args)
55{
56 mutex.lock();
57 unsigned int thread_id = *((unsigned int *)args);
58
59 std::cout << "Started job " << thread_counter << " with id " << thread_id << std::endl;
60
61 for (unsigned long i = 0; i < (0xFFFF); i++) {
62 };
63
64 std::cout << "Ended job " << thread_counter << std::endl;
65
66 thread_counter++;
67 mutex.unlock();
68
69 return 0;
70}
71
72int main(void)
73{
74 unsigned int nthread = 10;
75 vpThread *thread = new vpThread[nthread];
76 unsigned int *thread_id = new unsigned int[nthread];
77
78 for (unsigned int i = 0; i < nthread; i++) {
79 thread_id[i] = i;
80 thread[i].create((vpThread::Fn)&doSomeThing, (vpThread::Args)&thread_id[i]);
81 }
82
83 delete[] thread;
84 delete[] thread_id;
85
86 return EXIT_SUCCESS;
87}
88
89#else
90int main()
91{
92#if !defined(_WIN32) && (defined(__unix__) || defined(__unix) || (defined(__APPLE__) && defined(__MACH__))) // UNIX
93 std::cout << "You should enable pthread usage and rebuild ViSP..." << std::endl;
94#else
95 std::cout << "Multi-threading seems not supported on this platform" << std::endl;
96#endif
97}
98#endif
void unlock()
Definition vpMutex.h:106
void lock()
Definition vpMutex.h:90
void *(*) Fn(Args)
Definition vpThread.h:74
void * Args
Definition vpThread.h:72
void * Return
Definition vpThread.h:73
void create(vpThread::Fn fn, vpThread::Args args=NULL)
Definition vpThread.h:105