| 1 |
< |
/** |
| 2 |
< |
* Copyright (C) 2017 Fábio Bento (random-guy) |
| 3 |
< |
* |
| 4 |
< |
* This library is distributed under the MIT License. See notice at the end |
| 5 |
< |
* of this file. |
| 6 |
< |
* |
| 7 |
< |
*/ |
| 8 |
< |
|
| 9 |
< |
#ifndef CONDITIONALSEMAPHORE_H |
| 10 |
< |
#define CONDITIONALSEMAPHORE_H |
| 11 |
< |
|
| 12 |
< |
#include <atomic> |
| 13 |
< |
#include <stdexcept> |
| 14 |
< |
|
| 15 |
< |
/*** |
| 16 |
< |
* Conditional Semaphore - Thread safe conditional semaphore. You can set the variable by using SetCondition(), |
| 17 |
< |
* and unset it by using UnsetCondition() (you can set and unset multiple times). You can get the internal boolean variable state |
| 18 |
< |
* by using ConditionIsSet(). |
| 19 |
< |
* ConditionIsSet() return true when there were more calls to SetCondition() than to UnsetCondition() and |
| 20 |
< |
* false if there the calls to SetCondition() and UnsetCondition() were equal. |
| 21 |
< |
* |
| 22 |
< |
* UnsetCondition() throws an exception if it is called more than SetCondition(). |
| 23 |
< |
* */ |
| 24 |
< |
|
| 25 |
< |
namespace Cosemaphore{ |
| 26 |
< |
|
| 27 |
< |
class ConditionalSemaphore |
| 28 |
< |
{ |
| 29 |
< |
public: |
| 30 |
< |
ConditionalSemaphore(); |
| 31 |
< |
void SetCondition(); |
| 32 |
< |
void UnsetCondition(); |
| 33 |
< |
bool ConditionIsSet(); |
| 34 |
< |
private: |
| 35 |
< |
std::atomic<long long> internalCounter; |
| 36 |
< |
}; |
| 37 |
< |
|
| 38 |
< |
} |
| 39 |
< |
|
| 40 |
< |
#endif // CONDITIONALSEMAPHORE_H |
| 41 |
< |
|
| 42 |
< |
/** |
| 43 |
< |
* Copyright (c) 2017 |
| 44 |
< |
* |
| 45 |
< |
* Permission is hereby granted, free of charge, to any person |
| 46 |
< |
* obtaining a copy of this software and associated documentation |
| 47 |
< |
* files (the "Software"), to deal in the Software without |
| 48 |
< |
* restriction, including without limitation the rights to use, |
| 49 |
< |
* copy, modify, merge, publish, distribute, sublicense, and/or sell |
| 50 |
< |
* copies of the Software, and to permit persons to whom the |
| 51 |
< |
* Software is furnished to do so, subject to the following |
| 52 |
< |
* conditions: |
| 53 |
< |
* |
| 54 |
< |
* The above copyright notice and this permission notice shall be |
| 55 |
< |
* included in all copies or substantial portions of the Software. |
| 56 |
< |
* |
| 57 |
< |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, |
| 58 |
< |
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES |
| 59 |
< |
* OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND |
| 60 |
< |
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT |
| 61 |
< |
* HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, |
| 62 |
< |
* WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING |
| 63 |
< |
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR |
| 64 |
< |
* OTHER DEALINGS IN THE SOFTWARE. |
| 65 |
< |
*/ |
| 1 |
> |
/** |
| 2 |
> |
* Copyright (C) 2017 - 2018 Fábio Bento (fabiobento512) |
| 3 |
> |
* |
| 4 |
> |
* This library is distributed under the MIT License. See notice at the end |
| 5 |
> |
* of this file. |
| 6 |
> |
* |
| 7 |
> |
*/ |
| 8 |
> |
|
| 9 |
> |
#ifndef CONDITIONALSEMAPHORE_H |
| 10 |
> |
#define CONDITIONALSEMAPHORE_H |
| 11 |
> |
|
| 12 |
> |
#include <atomic> |
| 13 |
> |
#include <stdexcept> |
| 14 |
> |
|
| 15 |
> |
/*** |
| 16 |
> |
* Conditional Semaphore - Thread safe conditional semaphore. You can set the variable by using SetCondition(), |
| 17 |
> |
* and unset it by using UnsetCondition() (you can set and unset multiple times). You can get the internal boolean variable state |
| 18 |
> |
* by using ConditionIsSet(). |
| 19 |
> |
* ConditionIsSet() return true when there were more calls to SetCondition() than to UnsetCondition() and |
| 20 |
> |
* false if there the calls to SetCondition() and UnsetCondition() were equal. |
| 21 |
> |
* |
| 22 |
> |
* UnsetCondition() throws an exception if it is called more than SetCondition(). |
| 23 |
> |
* */ |
| 24 |
> |
|
| 25 |
> |
namespace Cosemaphore{ |
| 26 |
> |
|
| 27 |
> |
class ConditionalSemaphore |
| 28 |
> |
{ |
| 29 |
> |
public: |
| 30 |
> |
ConditionalSemaphore(); |
| 31 |
> |
void SetCondition(); |
| 32 |
> |
void UnsetCondition(); |
| 33 |
> |
bool ConditionIsSet(); |
| 34 |
> |
private: |
| 35 |
> |
std::atomic<long long> internalCounter; |
| 36 |
> |
}; |
| 37 |
> |
|
| 38 |
> |
} |
| 39 |
> |
|
| 40 |
> |
#endif // CONDITIONALSEMAPHORE_H |
| 41 |
> |
|
| 42 |
> |
/** |
| 43 |
> |
* Copyright (C) 2017 - 2018 Fábio Bento (fabiobento512) |
| 44 |
> |
* |
| 45 |
> |
* Permission is hereby granted, free of charge, to any person |
| 46 |
> |
* obtaining a copy of this software and associated documentation |
| 47 |
> |
* files (the "Software"), to deal in the Software without |
| 48 |
> |
* restriction, including without limitation the rights to use, |
| 49 |
> |
* copy, modify, merge, publish, distribute, sublicense, and/or sell |
| 50 |
> |
* copies of the Software, and to permit persons to whom the |
| 51 |
> |
* Software is furnished to do so, subject to the following |
| 52 |
> |
* conditions: |
| 53 |
> |
* |
| 54 |
> |
* The above copyright notice and this permission notice shall be |
| 55 |
> |
* included in all copies or substantial portions of the Software. |
| 56 |
> |
* |
| 57 |
> |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, |
| 58 |
> |
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES |
| 59 |
> |
* OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND |
| 60 |
> |
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT |
| 61 |
> |
* HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, |
| 62 |
> |
* WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING |
| 63 |
> |
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR |
| 64 |
> |
* OTHER DEALINGS IN THE SOFTWARE. |
| 65 |
> |
*/ |