mirror of
https://github.com/rdkit/rdkit.git
synced 2026-06-04 21:54:27 +08:00
4c0a99f2ad
* Add threaded pattern generator to help speed up library creation * Add size to FPHolderBase * Add more complete python wrapper, fix leak in doctest * Add basic usage test for addPatterns, fix I/O leak * Add basic test for trusted smiles * Actually add the new code * Export addPatterns on windows * Try fixing the cartridge build * Change pattern_factory to PatternFactory * Change boost::ref to std::ref
60 lines
1.7 KiB
C++
60 lines
1.7 KiB
C++
//
|
|
// Copyright (C) 2020 Brian P. Kelley
|
|
//
|
|
// @@ All Rights Reserved @@
|
|
// This file is part of the RDKit.
|
|
// The contents are covered by the terms of the BSD license
|
|
// which is included in the file license.txt, found at the root
|
|
// of the RDKit source tree.
|
|
//
|
|
#include "SubstructLibrary.h"
|
|
#include "PatternFactory.h"
|
|
|
|
#ifdef RDK_THREADSAFE_SSS
|
|
#include <thread>
|
|
#include <future>
|
|
#endif
|
|
|
|
namespace RDKit {
|
|
namespace {
|
|
void fillPatterns(const SubstructLibrary &slib,
|
|
const PatternHolder &fph,
|
|
std::vector<ExplicitBitVect*> &fps,
|
|
unsigned int start, unsigned int end, unsigned int numThreads) {
|
|
for (unsigned int idx = start;
|
|
idx < end;
|
|
idx += numThreads) {
|
|
fps[idx] = fph.makeFingerprint( *slib.getMol(idx).get() );
|
|
}
|
|
}
|
|
}
|
|
|
|
void addPatterns(SubstructLibrary &sslib, int numThreads) {
|
|
PRECONDITION(sslib.getFpHolder().get() == nullptr, "Substruct library already has fingerprints");
|
|
boost::shared_ptr<PatternHolder> ptr(new PatternHolder);
|
|
std::vector<ExplicitBitVect *> & fps = ptr->getFingerprints();
|
|
unsigned int startIdx = 0;
|
|
unsigned int endIdx = sslib.getMolecules().size();
|
|
fps.resize(endIdx);
|
|
|
|
#ifdef RDK_THREADSAFE_SSS
|
|
std::vector<std::future<void>> thread_group;
|
|
for (int thread_group_idx = 0; thread_group_idx < numThreads;
|
|
++thread_group_idx) {
|
|
// need to use std::ref otherwise things are passed by value
|
|
thread_group.emplace_back(
|
|
std::async(std::launch::async, fillPatterns,
|
|
std::ref(sslib), std::ref(*ptr.get()), std::ref(fps),
|
|
startIdx + thread_group_idx, endIdx, numThreads));
|
|
}
|
|
for (auto &fut : thread_group) {
|
|
fut.get();
|
|
}
|
|
#else
|
|
fillPaterns(lib, fps, 0, sslib.size(), 1);
|
|
#endif
|
|
|
|
sslib.getFpHolder() = ptr;
|
|
}
|
|
}
|