| 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 | > | */ |