Qt पर आलसी नक्शा

Qt में अनुक्रम के प्रत्येक सदस्य के लिए समानांतर में अपने फ़ंक्शन को निष्पादित करने की क्षमता है - QtConcurrent :: मैप्ड () और उसके दोस्त।

केवल एक ही समस्या है - परिणाम QVector में संग्रहीत हैं। इसलिए, जब मुझे 65 मिलियन डेटा के लिए अपने फ़ंक्शन को पूरा करने की आवश्यकता थी, तो मैंने रैम को पीड़ा नहीं दी, लेकिन एक ही चीज़ के बारे में लिखा, केवल अधिक आलसी, यानी नए मूल्यों की गणना केवल तभी की जाएगी जब पुराने पहले से ही उपयोग किए गए थे।

कोड: bitbucket.org/cblp/threadpool

हुड के नीचे

थ्रेडपूल क्यूथ्रेडपूल विरासत में मिला है। थ्रेडपूल :: मानचित्र () फ़ंक्शन इनपुट पर एक जावा-शैली पुनरावृत्ति स्वीकार करता है और एक रूपांतरण फ़ंक्शन, परिणाम के साथ एक जावा-शैली पुनरावृत्ति देता है।

आपका फ़ंक्शन QRunnable में लपेटा गया है और M = maxThreadCount टुकड़ों की संख्या में (आमतौर पर यह प्रोसेसर की संख्या है) इसे QThreadPool में फेंक दिया जाता है।

FutureIterator hasNext () और अगले () तरीके प्रदान करता है जो अगले परिणाम को लौटाते हैं, यदि कोई हो, या अगले परिणाम तैयार होने तक अवरुद्ध हो। यदि एम वर्तमान कार्य पूरा हो गया है, और कोई भी परिणाम के लिए नहीं आया है, तो कैलकुलेटर अवरुद्ध हैं।

उदाहरण

मानक इनपुट से तार पढ़ें, प्रत्येक से नमक के साथ एन-गुना एमडी 5 की गणना करें, मानक आउटपुट पर परिणाम लिखें। (यह एक बहुत ही संशोधित वास्तविक जीवन का उदाहरण है।)

const uint N = 10000; const QString Salt = "5417"; QByteArray md5_N_times(QString line) { QByteArray data = line.toUtf8(); for ( uint i = 0; i < N; ++i ) data = QCryptographicHash::hash(Salt.toUtf8() + data, QCryptographicHash::Md5); return data; } int main() { QTextStream input(stdin); QTextStream output(stdout); ThreadPool pool; FutureIterator<QByteArray> results = pool.map( QTextStreamIterator(input), md5_N_times ); while ( results.hasNext() ) output << results.next().toHex() << endl; return 0; } 

यह सब अभी भी बहुत नम है, उदाहरण के लिए, आप एक पूल में कई कार्य नहीं चला सकते हैं ताकि वे एक-दूसरे के साथ हस्तक्षेप न करें। आप अपने सुधार की पेशकश कर सकते हैं।