1

Помогите реализовать пример программы. Правильно ли я делаю или можно еще проще сделать? Ну и программа у меня зависает на строчке auto r = f.get(); Как сделать что бы потоки завершили работу, при нахождении одним из потока ключа? Это задача пример. То что она будет работать на моем компе 3 года это не важно.

#include <iostream>
#include <future>
#include <vector>

#define KEY_PASS  (0xFFAAFFAABBCCDDEE)

bool checkPass(uint64_t pass) {
    return pass == KEY_PASS;
}

const uint64_t STEP = 0x1000000000000000;

uint64_t funcAsync(uint64_t begin) {
    for (uint64_t i = 0; i < STEP; ++i) {
        if (checkPass(begin + i)) {
            return i;
        }
    }
    return uint64_t(-1);
}


int main() {
// Пример без работы с потоками
//    for (uint64_t i = 0; i < UINT64_MAX; ++i) {
//        if (checkPass(i)) {
//            std::cout << std::hex << i << std::endl;
//            break;
//        }
//    }
// Пример с потоками
    uint64_t i = 0;
    std::vector<std::future<uint64_t>> v;
    do {
        v.push_back(std::async(std::launch::async, funcAsync, i));
        i += STEP;
        std::cout << (i >> 60) << " open threads" << std::endl;
    } while (i != 0);
    for (auto& f: v) {
        auto r = f.get();
        if (r != uint64_t(-1)) {
            std::cout << std::hex << r << std::endl;
            break;
        }
    }
}
6
  • В этом примере работа с потоками отсутствует. Кроме того, сколько времени по-вашему займет выполнение funcAsync? 17 фев 2020 в 8:59
  • в целом я оптимально написал программу или можно/нужно сделать удобнее, лучше? funcAsync думаю отработает за 20 часов)
    – Kto To
    17 фев 2020 в 9:02
  • ок, может быть.. А как еще остановить программу если какой то из потоков нашел ответ?
    – Kto To
    17 фев 2020 в 9:05
  • 1
    В последнем потоке баг : 0xf0... + 0x10... = 0 цикл выходит сразу не работая.
    – AlexGlebe
    17 фев 2020 в 9:07
  • 1
    Теперь первый поток не будет пахать 0x0..0 & 0x01..1 == 0
    – AlexGlebe
    17 фев 2020 в 9:17

1 ответ 1

1
// $ g++ -std=c++11 -Wall -Wpedantic -Wextra -pthread futur.cpp -o futur
#include <iostream>
#include <future>
#include <vector>

#define KEY_PASS  (0xFFAAFFAABBCCDDEE)

bool checkPass(uint64_t pass) {
  return  (random() & 0xff) == 0 ;
    //return pass == KEY_PASS;
}

const uint64_t STEP = 0x1000000000000000;

volatile std ::  atomic  < bool  > flag_stop{ false };

struct s_result {
  bool  valid ;
  uint64_t value ;
} ;

s_result funcAsync(uint64_t begin) {
    for (uint64_t i = 0; i < STEP; ++i) {
        if ( flag_stop ) s_result{false,uint64_t(-1)};
        if (checkPass(begin+i)) {
            flag_stop = true ;
            return s_result{true,begin + i};
        }
    }
    return s_result{false,uint64_t(-1)};
}


int main() {
// Пример без работы с потоками
//    for (uint64_t i = 0; i < UINT64_MAX; ++i) {
//        if (checkPass(i)) {
//            std::cout << std::hex << i << std::endl;
//            break;
//        }
//    }
// Пример с потоками
  srandom(time(nullptr));
    uint64_t i = 0;
    std::vector<std::future<s_result>> v;
    do {
        v.push_back(std::async(std::launch::async, funcAsync, i));
        i += STEP;
        std::cout << (i >> 60) << " open threads" << std::endl;
    } while (i != 0);
    for (auto& f: v) {
        auto r = f.get();
        if ( r.valid ) {
          std::cout << "found " << std::hex << r.value << std::endl;
          break;
        }

    }
}

Ваш ответ

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

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