10#ifdef RDK_BUILD_THREADSAFE_SSS
11#ifndef MULTITHREADED_SD_MOL_SUPPLIER
12#define MULTITHREADED_SD_MOL_SUPPLIER
16namespace FileParsers {
23 explicit MultithreadedSDMolSupplier(
24 const std::string &fileName,
const Parameters ¶ms = Parameters(),
25 const MolFileParserParams &parseParams = MolFileParserParams());
27 explicit MultithreadedSDMolSupplier(
28 std::istream *inStream,
bool takeOwnership =
true,
29 const Parameters ¶ms = Parameters(),
30 const MolFileParserParams &parseParams = MolFileParserParams());
32 MultithreadedSDMolSupplier();
33 ~MultithreadedSDMolSupplier()
override;
34 void init()
override {}
37 bool getEnd()
const override;
38 void setProcessPropertyLists(
bool val) { df_processPropertyLists = val; }
39 bool getProcessPropertyLists()
const {
return df_processPropertyLists; }
40 bool getEOFHitOnRead()
const {
return df_eofHitOnRead; }
43 bool extractNextRecord(std::string &record,
unsigned int &lineNum,
44 unsigned int &index)
override;
45 void readMolProps(RWMol &mol, std::istringstream &inStream);
47 RWMol *processMoleculeRecord(
const std::string &record,
48 unsigned int lineNum)
override;
51 void initFromSettings(
bool takeOwnership,
const Parameters ¶ms,
52 const MolFileParserParams &parseParams);
57 bool df_processPropertyLists =
true;
58 bool df_eofHitOnRead =
false;
59 unsigned int d_currentRecordId = 1;
60 MolFileParserParams d_parseParams;
70 using ContainedType = v2::FileParsers::MultithreadedSDMolSupplier;
71 MultithreadedSDMolSupplier() {}
72 explicit MultithreadedSDMolSupplier(
73 const std::string &fileName,
bool sanitize =
true,
bool removeHs =
true,
74 bool strictParsing =
true,
unsigned int numWriterThreads = 1,
75 size_t sizeInputQueue = 5,
size_t sizeOutputQueue = 5) {
76 v2::FileParsers::MultithreadedSDMolSupplier::Parameters params;
77 params.numWriterThreads = numWriterThreads;
78 params.sizeInputQueue = sizeInputQueue;
79 params.sizeOutputQueue = sizeOutputQueue;
80 v2::FileParsers::MolFileParserParams parseParams;
81 parseParams.sanitize = sanitize;
83 parseParams.strictParsing = strictParsing;
85 dp_supplier.reset(
new v2::FileParsers::MultithreadedSDMolSupplier(
86 fileName, params, parseParams));
89 explicit MultithreadedSDMolSupplier(
90 std::istream *inStream,
bool takeOwnership =
true,
bool sanitize =
true,
91 bool removeHs =
true,
bool strictParsing =
true,
92 unsigned int numWriterThreads = 1,
size_t sizeInputQueue = 5,
93 size_t sizeOutputQueue = 5) {
94 v2::FileParsers::MultithreadedSDMolSupplier::Parameters params;
95 params.numWriterThreads = numWriterThreads;
96 params.sizeInputQueue = sizeInputQueue;
97 params.sizeOutputQueue = sizeOutputQueue;
98 v2::FileParsers::MolFileParserParams parseParams;
99 parseParams.sanitize = sanitize;
101 parseParams.strictParsing = strictParsing;
103 dp_supplier.reset(
new v2::FileParsers::MultithreadedSDMolSupplier(
104 inStream, takeOwnership, params, parseParams));
108 bool getEOFHitOnRead()
const {
110 return static_cast<ContainedType *
>(dp_supplier.get())->getEOFHitOnRead();
119 unsigned int getLastRecordId()
const {
121 return static_cast<ContainedType *
>(dp_supplier.get())->getLastRecordId();
124 std::string getLastItemText()
const {
126 return static_cast<ContainedType *
>(dp_supplier.get())->getLastItemText();
128 void setProcessPropertyLists(
bool val) {
130 static_cast<ContainedType *
>(dp_supplier.get())
131 ->setProcessPropertyLists(val);
133 bool getProcessPropertyLists()
const {
135 return static_cast<ContainedType *
>(dp_supplier.get())
136 ->getProcessPropertyLists();
#define PRECONDITION(expr, mess)
#define RDKIT_FILEPARSERS_EXPORT
RDKIT_GRAPHMOL_EXPORT ROMol * removeHs(const ROMol &mol, bool implicitOnly=false, bool updateExplicitCount=false, bool sanitize=true)
returns a copy of a molecule with hydrogens removed
bool rdvalue_is(const RDValue_cast_t)