Method parse_cpuset

src/bthread/task_control.cpp:331–365

}

int TaskControl::parse_cpuset(std::string value, std::vector<unsigned>& cpus) {
    static std::regex r("(\\d+-)?(\\d+)(,(\\d+-)?(\\d+))*");
    std::smatch match;
    std::set<unsigned> cpuset;
    if (value.empty()) {
        return -1;
    }
    if (std::regex_match(value, match, r)) {
        for (butil::StringSplitter split(value.data(), ','); split; ++split) {
            butil::StringPiece cpu_ids(split.field(), split.length());
            cpu_ids.trim_spaces();
            butil::StringPiece begin = cpu_ids;
            butil::StringPiece end = cpu_ids;
            auto dash = cpu_ids.find('-');
            if (dash != cpu_ids.npos) {
                begin = cpu_ids.substr(0, dash);
                end = cpu_ids.substr(dash + 1);
            }
            unsigned first = UINT_MAX;
            unsigned last = 0;
            int ret;
            ret = butil::StringSplitter(begin, '\t').to_uint(&first);
            ret = ret | butil::StringSplitter(end, '\t').to_uint(&last);
            if (ret != 0 || first > last) {
                return -1;
            }
            for (auto i = first; i <= last; ++i) {
                cpuset.insert(i);
            }
        }
        cpus.assign(cpuset.begin(), cpuset.end());
        return 0;
    }
    return -1;
}

void TaskControl::bind_thread_to_cpu(pthread_t pthread, unsigned cpu_id) {
#if defined(OS_LINUX)