1

Предположим есть функция, которая симулирует клик мышки. Время клика регулируется аргументом. При этом клик происходит в отдельном потоке, чтобы главный поток на время клика продолжал работать:

Mouse::Click(std::chrono::milliseconds)
{
    namespace thr = std::this_thread;
    std::thread mouseClickThread{[](){/* .... */}};
    mouseClickThread.detach();
}

Однако такой код может привести к тому, что пока кнопка мыши опущена и ждет указанное время, в основном потоке может снова быть вызвана функция Click() и тогда запустится ещё один поток с кликанием, что неправильно.

Как правильно синхронизировать потоки и нужно ли тут использовать мьютексы? Если да, то как? Я пока слаб в многопоточности, поэтому не понимаю, как это нужно использовать. join() - не вариант, я не хочу останавливать основной поток

2 ответа 2

3

UPD:

Вариант 1 - довольно простой, но с точки зрения архитектуры к нему могут быть вопросы. И кода вопроса передаваемых в новый поток или из него, выгоднее выглядит использовать связку std::future<T> mouseFuture + std::async. Как-то так:

/// mouse.cpp 

std::future<void> myFuture;

Mouse::Click(std::chrono::milliseconds)
{
    // При первом запуске функции myFuture.valid() будет false. Просто объявили myFuture
    // https://en.cppreference.com/w/cpp/thread/future/valid
    if(!myFuture.valid()) {
        using namespace std::chrono_literals;
        // std::launch имеет 2 вариант запуска выбираете удобный 
        // https://en.cppreference.com/w/cpp/thread/launch
        // Параметр запуска std::launch::async гарантирует асинхронность работать
        myFuture = std::async(std::launch::async, []() {
            /// Some beautiful magic here ///
        });
    }
}

При вызове функции Click() до конца выполнения задачи valid() == true и запуска еще одного не будет.

Можно попробовать обернуть как-то так для удобства( пример на коленке ). Если доулучшить вполне годное решение можно получить для такого рода задач.

template<typename T>
struct FutureWrapper{
    bool isReady() const { return future.valid(); }
    T get()  { return future.get();}
    std::future<T> future;
};

template<typename T>
class AsyncCaller {
public:
    template<typename Callback, typename ... Args>
    FutureWrapper<T>& callAsyncOnce(Callback&& callback, Args&& ... args) {
        if(!m_currentFuture.isReady())
            m_currentFuture.future = std::async(std::launch::async,
                                                std::forward<Callback>(callback),
                                                        std::forward<Args>(args)...);
        return m_currentFuture;
    }
private:
     FutureWrapper<T> m_currentFuture;
};

/// Mouse.cpp
Mouse::Click(std::chrono::milliseconds ms) {
   /// AsyncCaller<T> asyncCaller; хранить где-то выше.
   auto& futureTask = asyncCaller.callAsyncOnce([](){
       /// ... ///
   });
   /// что-то делать с futureTask 
}
8
  • Нет, вы в корне неправильно поняли вопрос. Перечитайте его ещё раз.
    – ComeInRage
    5 ноя 2022 в 18:47
  • @ComeInRage а можете, как-то пожалуйста, дополнительно описать или псевдо код написать что вы хотите на выходе.
    – moglio
    5 ноя 2022 в 19:44
  • Я вам и там всё описал и предоставил код. Что не понятно? Есть функция, которая вызывается в отдельном потоке. Как не допустить её повторного вызова, пока поток выполняется? Точнее какой способ наиболее правильный?
    – ComeInRage
    6 ноя 2022 в 18:48
  • 1
    @ComeInRage я в своём ответе в варианте вам предложил вариант, только использовать не std::thread, а std::async + future, с запуском std::launch::async, что так же сделает задачу не основном потоке, и с помощью метода valid() позволит защититься от повторных срабатываний пока работа не будет выполнена.
    – moglio
    6 ноя 2022 в 20:22
  • 1
    У Скотта Мейерса есть хорошая глава за std::async , почитатайте 7.1 и 7.2 пункты главы 7. coollib.net/b.usr/…. Думаю так вам будет понятнее что я вам предлагаю
    – moglio
    6 ноя 2022 в 20:24
1

Непосредственно для избежания двойной обработки клика вам не требуется никаких хитростей кроме булевой переменной (точнее, атомарной булевой переменной, ведь вы будете работать с ней из разных потоков):

std::atomic<bool> click_processing; // эта переменная не может быть локальной!

// …

if (click_processing.load()) return;
click_processing.store(true);
std::thread mouseClickThread{[&click_processing](){
  /* … */
  click_processing.store(false);
}};
mouseClickThread.detach();

Ну и про обработку ошибок не забудьте.


Однако, игнорировать клики пользователя просто так - не лучшая идея, по-хорошему вам надо заблокировать соответствующие кнопки на время асинхронной операции. Как это делать - зависит от используемой вами библиотеки.

А если вы их блокируете - надо будет и разблокировать обратно, для чего понадобится по окончанию работы потока "вернуться" в поток UI. Как это сделать - тоже зависит целиком от библиотеки, к примеру в случае WinAPI это будет вызов PostMessage с сообщением WM_USER. Если вы пойдёте по этому пути - то и синхронизировать вам будет ничего не надо, передача сообщения и будет механизмом синхронизации:

bool click_processing; // эта переменная не может быть локальной!

// …

if (click_processing) return;
click_processing = true;
// тут блокируем (disable) кнопку

std::thread mouseClickThread{[&click_processing](){
  /* … */
  
  invoke_on_ui_thread_somehow([&click_processing]() {
    click_processing = false;
    // тут разблокируем (enable) кнопку
  });
}};
mouseClickThread.detach();

Ах да, последнее уточнение: создавать по потоку на каждый клик - ужасное решение, потоки дорогие. Поищите библиотеку для пула потоков, или воспользуйтесь системным пулом если вы пишете под винду.

Готовых решений на чистом с++ нет, если вы выбрали этот язык - страдайте!

1
  • Эмуляция клика не равно обработке клика пользователя. Это совершенно разные вещи :) Ваш ответ не совсем подходит, но я учту такой вариант решения проблемы
    – ComeInRage
    9 ноя 2022 в 21:33

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.