Merge pull request #93605 from RadiantUwU/thread-barriers

Add optional count argument to `Semaphore::post`
This commit is contained in:
Rémi Verschelde 2024-08-27 22:27:21 +02:00
commit 8ae2c3a000
No known key found for this signature in database
GPG Key ID: C3336907360768E1
5 changed files with 65 additions and 5 deletions

45
core/core_bind.compat.inc Normal file
View File

@ -0,0 +1,45 @@
/**************************************************************************/
/* core_bind.compat.inc */
/**************************************************************************/
/* This file is part of: */
/* GODOT ENGINE */
/* https://godotengine.org */
/**************************************************************************/
/* Copyright (c) 2014-present Godot Engine contributors (see AUTHORS.md). */
/* Copyright (c) 2007-2014 Juan Linietsky, Ariel Manzur. */
/* */
/* Permission is hereby granted, free of charge, to any person obtaining */
/* a copy of this software and associated documentation files (the */
/* "Software"), to deal in the Software without restriction, including */
/* without limitation the rights to use, copy, modify, merge, publish, */
/* distribute, sublicense, and/or sell copies of the Software, and to */
/* permit persons to whom the Software is furnished to do so, subject to */
/* the following conditions: */
/* */
/* The above copyright notice and this permission notice shall be */
/* included in all copies or substantial portions of the Software. */
/* */
/* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
/* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
/* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. */
/* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
/* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
/* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
/* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
/**************************************************************************/
#ifndef DISABLE_DEPRECATED
namespace core_bind {
void Semaphore::_post_bind_compat_93605() {
post(1);
}
void Semaphore::_bind_compatibility_methods() {
ClassDB::bind_compatibility_method(D_METHOD("post"), &Semaphore::_post_bind_compat_93605);
}
}; // namespace core_bind
#endif

View File

@ -29,6 +29,7 @@
/**************************************************************************/ /**************************************************************************/
#include "core_bind.h" #include "core_bind.h"
#include "core_bind.compat.inc"
#include "core/config/project_settings.h" #include "core/config/project_settings.h"
#include "core/crypto/crypto_core.h" #include "core/crypto/crypto_core.h"
@ -1210,14 +1211,15 @@ bool Semaphore::try_wait() {
return semaphore.try_wait(); return semaphore.try_wait();
} }
void Semaphore::post() { void Semaphore::post(int p_count) {
semaphore.post(); ERR_FAIL_COND(p_count <= 0);
semaphore.post(p_count);
} }
void Semaphore::_bind_methods() { void Semaphore::_bind_methods() {
ClassDB::bind_method(D_METHOD("wait"), &Semaphore::wait); ClassDB::bind_method(D_METHOD("wait"), &Semaphore::wait);
ClassDB::bind_method(D_METHOD("try_wait"), &Semaphore::try_wait); ClassDB::bind_method(D_METHOD("try_wait"), &Semaphore::try_wait);
ClassDB::bind_method(D_METHOD("post"), &Semaphore::post); ClassDB::bind_method(D_METHOD("post", "count"), &Semaphore::post, DEFVAL(1));
} }
////// Mutex ////// ////// Mutex //////

View File

@ -390,12 +390,17 @@ class Semaphore : public RefCounted {
GDCLASS(Semaphore, RefCounted); GDCLASS(Semaphore, RefCounted);
::Semaphore semaphore; ::Semaphore semaphore;
protected:
static void _bind_methods(); static void _bind_methods();
#ifndef DISABLE_DEPRECATED
void _post_bind_compat_93605();
static void _bind_compatibility_methods();
#endif // DISABLE_DEPRECATED
public: public:
void wait(); void wait();
bool try_wait(); bool try_wait();
void post(); void post(int p_count = 1);
}; };
class Thread : public RefCounted { class Thread : public RefCounted {

View File

@ -17,8 +17,9 @@
<methods> <methods>
<method name="post"> <method name="post">
<return type="void" /> <return type="void" />
<param index="0" name="count" type="int" default="1" />
<description> <description>
Lowers the [Semaphore], allowing one more thread in. Lowers the [Semaphore], allowing one thread in, or more if [param count] is specified.
</description> </description>
</method> </method>
<method name="try_wait"> <method name="try_wait">

View File

@ -41,3 +41,10 @@ Validate extension JSON: Error: Field 'classes/VisualShaderNodeTexture2DArray/pr
Allow setting a cubemap as default parameter to shader. Allow setting a cubemap as default parameter to shader.
Compatibility methods registered. Compatibility methods registered.
GH-93605
--------
Validate extension JSON: JSON file: Field was added in a way that breaks compatibility 'classes/Semaphore/methods/post': arguments
Optional arguments added. Compatibility methods registered.