Ответы пользователя code_panik по тегу «C++»

Как использовать потоки в современном C++ в приложении на основе цикла событий?

code_panik @code_panik

В сущности, async - это thread + promise/future с удобствами: его не нужно join-нить руками, не нужно создавать промежуточный promise, а возвращенный функцией результат и исключения можно получить в вызывающем коде. При этом деструктор объекта future, полученного в результате вызова async, блокирует вызывающий поток до завершения нашей async-функции.
В нашем случае разницы с использованием thread в части отправки сигналов нет, ведь нам по-прежнему придется сигнализировать виджету о завершении сканирования. Это можно сделать в самой функции сканирования. Если я правильно понял, раньше мы это делали в функции scanFinished, которая вызывалась в конце функции сканирования.
Под задачами обычно понимают независимые потоки выполнения (необязательно параллельно), которые можно запустить и забыть, а в конце забрать результат. Потоки сканирования директорий, судя по коду из вопроса, не зависят друг от друга, и мы наш ThreadManager можем разбить на две переменные типа ScanTask

#include <iostream>
#include <future>
#include <atomic>
#include <memory>
#include <string>

class ScanTask {
public:
	struct Result {
		enum {
			Success, Failure, Canceled
		} status;
		std::string message;
	};

	ScanTask(const std::string& dir)
		: canceled_{ false },
		result_{std::async(&ScanTask::scan, this, dir)}
	{ }

	void cancel() {
		canceled_ = true;
	}

	Result result() { 
		return result_.get(); // result_.valid() == false
	}

	Result scan(const std::string& dir) {
		struct Finalize {
			~Finalize() {
				// emit signal scan completed
			}
		} finalizeSignal;

		while (!canceled_ /* && not done */) {
			// .. scan subdirectories
			/*
			if (something failed)
				return {Result::Failure, "Failure"};
			*/
		}
		if (canceled_)
			return { Result::Canceled, std::string("[Canceled] ") + dir };
		return { Result::Success, std::string("[Success] ") + dir };
	}

private:
	std::atomic<bool> canceled_;
	std::future<Result> result_;
};

int main() {
	auto localScanTask = std::make_unique<ScanTask>("a");
	localScanTask->cancel();
	std::cout << localScanTask->result().message << std::endl;

	auto sharedScanTask = std::make_unique<ScanTask>("b");
	sharedScanTask->cancel();
	std::cout << sharedScanTask->result().message << std::endl;
	return 0;
}

Можно было даже не создавать отдельный класс, а в функции-обработчике нажатия кнопки запуска присваивать future члену виджета результат вызова async от анонимной лямбды, как предлагали с thread в ревью. При этом atomic canceled_ можно захватить по ссылке, она была бы общей для всех.

Ответ написан 13 окт. 2023

Комментировать

Как переделать код под ООП?

code_panik @code_panik

Сначала замечу, что нет никакого смысла переписывать код в стиле ООП, потому что класс, назовем его Calculator, не имеет состояния, не хранит данных, состоит только из функций. То есть весь код будет выглядеть как раньше, но придется приписывать в начало операций имя объекта класса типа Calculator, напр. calculator.divide(1, 2);. Достаточно собрать эти функции в нашем пространстве имен my_math, например,

namespace my_math {
bool operator<(const std::string& st1, const std::string& st2) {
    size_t len1 = st1.length();
    size_t len2 = st2.length();
    if (len1 != len2) return (len1 < len2);
    long int i = 0;
        // ищем разряд, в котором значения отличаются
    while (i < len1 && st1[i] == st2[i])
    {
        i++;
    }
        // если разряд найден, то меньше число с меньшей цифрой для положительных и с большей цифрой для отрицательных, иначе числа равны
    return (i < len1) && ((st1[i] < st2[i]) );
}
bool les(int lhs, int rhs) {
    return lhs <= rhs;
}
}

int main() {
    using my_math::operator<; // иначе cout << my_math::operator<(s1, s2) << endl;
    std::string s1 = "1", s2 = "2";
    cout << (s1 < s2) << endl;

    int a = 1, b = 2;
    cout << (my_math::les(a, b)) << endl;
    return 0;
}

Для ООП можно воспользоваться примером https://godbolt.org/z/rEPzdKe4j. В нем определены два файла: calculator.h и calculator.cpp с объявлением класса и реализацией соответственно.
Замечу, что в реализациях бинарных операций не следует передавать string по значению, чтобы избежать лишних копирований. Если заменить тип аргумента std::string на ссылочный const std::string&, придется поправить код, чтобы он не изменял значения аргументов.

Ответ написан 11 окт. 2023

Комментировать

C++ | Почему новый поток со временем периодически перестаёт работать?

code_panik @code_panik

Наиболее вероятная проблема - race condition (состояние гонки) + ub (неопределенное поведение) из-за проблем синхронизации основного потока, в котором вызывается деструктор ~MyClass, и потока thr_dPManager.
Пусть в основном потоке вызывается деструктор, но exit_flag_dPManager = false, тогда this->thr_dPManager.join(); не выполнится (race condition) и без ожидания завершения run() в основном потоке будут тихо освобождены все данные связанные с объектом класса и объектом потока thr_dPManager. В run() мы попытаемся обратиться к освобожденным данным класса (ub) и получим непредсказуемое поведение программы. В c++ для каждого потока мы должны корректно вызывать join или detach. Вынесем join из if,

MyClass::~MyClass()
{
    if (this->exit_flag_dPManager)
        this->exit_flag_dPManager = false;

    if (thr_dPManager.joinable())
        thr_dPManager.join();
}

Осталось проверить логику программы и убедиться, что "бесконечный" цикл завершится. Пока непонятно, зачем в деструкторе строка this->exit_flag_dPManager = false, ведь после завершения деструктора у нас не будет доступа к данным класса.
Если exit_flag_dPManager используется для синхронизации: завершить run, если завершается основной поток, — тогда можно писать

MyClass() : exit_flag_dPManager(false) ....

void run() {
  while (!exit_flag_dPManager.load()) { ... }
}

~MyClass() {
  this->exit_flag_dPManager = true;

  if (thr_dPManager.joinable())
    thr_dPManager.join();
}

Также нужно иметь в виду потенциальные проблемы из статьи https://habr.com/ru/articles/444464/.

Ответ написан 06 июл. 2023

Комментировать

C++. Почему в консоли выводит непонятные символы, хотя setlocale(LC_ALL, &quot;RU&quot;) прописан?

code_panik @code_panik

Если кратко, то у windows беда с многообразием представлений символов (кодировок) в терминале. Есть однобайтовые 866 (стандартная терминала), 1251 (ansi), есть многобайтовая 65001 (utf-8). Чтобы проверить кодировку, в терминале наберите chcp. Если нет особых требований к работе с кодировками, достаточно обычного подхода

#include <iostream>
#include <string>
using namespace std;

int main()
{
  string words;
  cin >> words;
  cout << words;
  return 0;
}

Пример работает с 866 и 1251.
Если нужна кодировка 1251 (и она не выбрана для терминала по умолчанию при запуске), запускайте программу из подготовленного окна терминала. Для этого в терминале наберите сначала однажды chcp 1251. Кодировка может понадобиться, если в исходном коде программы в кодировке 1251 будут строки с кириллицей.

Ответ написан 04 июл. 2023

Комментировать

Какие виды функций есть в C++, и как их различать?

code_panik @code_panik

В c++ есть бинарный оператор <<, который для целых чисел является оператором сдвига битов числа влево на заданное количество позиций (то же, что и повторное умножение на два). Например, программа напечатает 2 << 1 == 4,

#include <iostream>
using namespace std;

int main() {
    cout << "2 << 1 == " << (0b010 << 1); // 0b100
    return 0;
}

Одна из основных возможностей языка - перегрузка функций, в частности встроенных операторов (не всех). То есть мы можем определить свой тип данных со своей реализацией оператора <<.

#include <iostream>
using namespace std;

struct Foo {
    Foo& operator<<(int x) {
        cout << "Integer: " << x << '\n';
        return *this;
    }

    Foo& operator<<(const char* str) {
        cout << "String: " << str << '\n';
        return *this;
    }
};

int main() {
    Foo foo;
    foo << 3; // Integer: 3
    foo.operator<<("Hello world"); // String: Hello world
    return 0;
}

Для компилятора запись foo << 3; значит именно вызов функции foo.operator<<(3). Аналогично в случае cout, объекта типа std::ostream, который представляет поток вывода (character output).
https://en.cppreference.com/w/cpp/io/basic_ostream...

Ответ написан 29 июн. 2023

Комментировать

Как в c++ сохранить txt файл в кодировке ansi?

code_panik @code_panik

Под ANSI обычно подразумевается однобайтовая кодировка Windows-1251.

Синонимы: CP1251; ANSI (только в русскоязычной ОС Windows).

Символ типа char в C++ всегда имеет размер 1 байт, поэтому работаем с файлом самым обычным образом. Прочитанное содержимое (возможно части) файла можно сохранить в буфере типа std::string или массиве char. Файл в программе можно представить объектом потока: std::ifstream, std::ofstream, std::fstream. Выходной файл, в который запишем содержимое полученного таким образом буфера, будет иметь ту же кодировку ANSI.

Проще всего прочитать всё содержимое файла в буфер и потом перезаписать файл полностью, например так.

#include <fstream>
#include <string>

 int main() {
	 const std::string path = "<путь к файлу>";
	 std::fstream file(path, std::ios::in);
	 std::string text;
	 std::getline(file, text, '\0');
	 file.close();

	 text += "[edit]\n";

	 file.open(path, std::ios::out);
	 file << text;
	 return 0;
 }

Войдите на сайт