🕎 🏳️ 🐲 क्यूथ्रेड का उचित उपयोग 🦀 👨🏿‍💻 🙇🏾

क्यूटी के साथ एक हालिया परियोजना में, मुझे क्यूथ्रेड वर्ग से निपटना पड़ा। नतीजतन, मैं "सही" क्यूथ्रेड तकनीक के लिए आया था, जिसे मैं अन्य परियोजनाओं में उपयोग करूंगा।

कार्य

एक सेवा है जो सैकड़ों, हजारों की संख्या में फ़ाइलों की संख्या से काफी बड़े निर्देशिका की निगरानी करती है। फ़ाइलों की सामग्री के विश्लेषण के आधार पर, रिपोर्ट बनाई जाती हैं (विभिन्न प्रकार की पांच रिपोर्टों तक)। यदि किसी फ़ाइल की सामग्री बदलती है, या फ़ाइलों की संख्या बदलती है, तो रिपोर्टिंग बाधित होती है और खत्म हो जाती है। ReportBuilder वर्ग में रिपोर्ट बिल्डिंग कार्यक्षमता कार्यान्वित की जाती है। प्रत्येक प्रकार की रिपोर्ट ReportBuilder से विरासत में मिली अपनी कक्षा का उपयोग करती है। समानांतर धागे में रिपोर्ट बनाने की सलाह दी जाती है।

Qt प्रलेखन उदाहरण: गलत

प्रलेखन और Qt उदाहरणों को पढ़कर शुरू किया। सभी उदाहरणों में, थ्रेड क्यूथ्रेड वर्ग को इनहेरिट करके और run() विधि को ओवरराइड करके बनाया गया है:

 class MyThread : public QThread { Q_OBJECT protected: void run(); }; void MyThread::run() { ... }

मैं जिस तरह से क्यूटी ब्रैडली टी। ह्यूजेस डेवलपर का दावा करता हूं कि एक पोस्ट पढ़ता हूं कि क्यूथ्रेड को केवल एक अलग धागे में वर्ग कोड निष्पादित करने के लिए विरासत में मिला है, एक मौलिक रूप से गलत विचार है:
"क्यूथ्रेड को डिज़ाइन किया गया था और इसे एक ऑपरेटिंग सिस्टम थ्रेड के लिए एक इंटरफ़ेस या नियंत्रण बिंदु के रूप में उपयोग करने का इरादा है, न कि उस कोड को रखने के लिए एक जगह के रूप में जिसे आप एक थ्रेड में चलाना चाहते हैं। हम ऑब्जेक्ट-ओरिएंटेड प्रोग्रामर्स सबक्लास को आधार बनाते हैं क्योंकि हम बेस क्लास की कार्यक्षमता को बढ़ाना या विशेषज्ञ करना चाहते हैं। केवल मान्य कारण जो मैं सोच सकता हूं कि क्यूथ्रेड को उप-वर्ग में रखने के लिए कार्यक्षमता को जोड़ना है जो कि क्यूथ्रेड के पास नहीं है, उदाहरण के लिए शायद थ्रेड के स्टैक के रूप में उपयोग करने के लिए मेमोरी को एक पॉइंटर प्रदान करना, या संभवतया रीयल-टाइम इंटरफेस / समर्थन जोड़ना। किसी फ़ाइल को डाउनलोड करने के लिए, या किसी डेटाबेस को क्वेरी करने के लिए, या किसी अन्य प्रकार की प्रोसेसिंग को क्यूआरएड के उपवर्ग में नहीं जोड़ा जाना चाहिए; यह अपने आप में एक वस्तु के रूप में समझाया जाना चाहिए। ”

“क्यूथ्रेड वर्ग बनाया गया था और इसे ऑपरेटिंग सिस्टम के थ्रेड्स के लिए एक इंटरफ़ेस के रूप में उपयोग करने के लिए बनाया गया था, लेकिन कोड को अलग थ्रेड में निष्पादित करने के उद्देश्य से नहीं। OOP में, हम बेस क्लास की कार्यक्षमता का विस्तार करने या गहरा करने के लिए एक वर्ग प्राप्त करते हैं। क्यूथ्रेड वंशानुक्रम के लिए एकमात्र औचित्य जो मैं कल्पना कर सकता हूं कि कार्यक्षमता को जोड़ रहा है कि क्यूथ्रेड मौजूद नहीं है, उदाहरण के लिए, एक मेमोरी क्षेत्र के लिए एक पॉइंटर पास करना जो थ्रेड इसके स्टैक के लिए उपयोग कर सकता है, या संभवतः वास्तविक समय इंटरफेस के लिए समर्थन जोड़ सकता है। फ़ाइल लोड हो रहा है, डेटाबेस के साथ काम कर रहा है, और इसी तरह के कार्यों को विरासत में मिले क्यूथ्रेड कक्षाओं में मौजूद नहीं होना चाहिए; उन्हें अन्य सुविधाओं में लागू किया जाना चाहिए ”

यानी क्यूथ्रेड से विरासत पूरी तरह से गलत नहीं है, लेकिन एक वर्ग में कार्यों के विभिन्न सेटों के अनावश्यक मिश्रण की ओर जाता है, जो कोड की पठनीयता और स्थिरता को कम करता है। लेकिन, अगर क्यूथ्रेड को विरासत में देना गलत है, तो यह सही कैसे है? एक छोटी खोज के बाद, मुझे यह पोस्ट यहाँ मिली, जिसमें सब कुछ अलमारियों पर रखा गया है। पोस्ट के मुख्य बिंदु:

क्यूथ्रेड एक धागा नहीं है, लेकिन एक विशिष्ट ओएस थ्रेड के लिए एक क्यूटी रैपर है, जो आपको क्यूटी प्रोजेक्ट से थ्रेड के साथ बातचीत करने की अनुमति देता है, मुख्य रूप से क्यूटी सिग्नल / स्लॉट्स के माध्यम से।
नए ऑपरेटर द्वारा एक अलग थ्रेड में निष्पादित किए जाने वाले वर्ग के उदाहरणों के लिए मेमोरी का आवंटन पहले से ही थ्रेड में किया जाना चाहिए। ऑब्जेक्ट का स्वामी वह थ्रेड होगा जो ऑब्जेक्ट को मेमोरी आवंटित करता है।
धाराओं और वस्तुओं को "जीवित" करने के लिए उन्हें प्रबंधित करने के लिए, संदेश को ठीक से कॉन्फ़िगर करना महत्वपूर्ण है।

कैसे करें?

तो धागे में कक्षाएं शुरू करने और रोकने के लिए "सही" नुस्खा:

हम एक वर्ग के लिए एक आवरण बनाते हैं जो एक अलग थ्रेड में रहेगा। हमारे मामले में, यह ReportBuilder । इसके लिए लपेटें: RBWorker ।

 class RBWorker : public QObject { Q_OBJECT private: ReportBuilder *rb; /*   */ QStringList file_list; /*     */ ReportType r_type; /*   */ public: RBWorker(ReportType p_type ); ~RBWorker(); void setFileList(const QStringList &files) { file_list = files; } /*      */ public slots: void process(); /*      */ void stop(); /*    */ signals: void finished(); /*       */ }; RBWorker:: RBWorker (ReportType p_type) { rb = NULL; r_type = p_type; } RBWorker::~ RBWorker () { if (rb != NULL) { delete rb; } } void RBWorker::process() { if(file_list.count() == 0) { emit finished(); return; } switch (r_type) { case REPORT_A: { rb = new ReportBuilderA (); break; } case REPORT_B: { rb = new ReportBuilderB (); break; } case REPORT_C: { rb = new ReportBuilderC (); break; } default: emit finished(); return ; } } rb->buildToFile(file_list); /*  buildToFile   rb->stop() */ emit finished(); return ; } void RBWorker::stop() { if(rb != NULL) { rb->stop(); } return ; }

एक महत्वपूर्ण बिंदु: RBWorker एक उदाहरण process(), विधि में बनाया गया है process(), और RBWorker निर्माता में नहीं।

Session वर्ग ट्रैक फाइलों में बदल जाता है और रिपोर्ट करना शुरू कर देता है।

 class Session : public QObject { Q_OBJECT public: Session(QObject *parent, const QString &directory, const QVector<ReportType> &p_rt); ~Session(); void buildReports(); private: void addThread(ReportType r_type); void stopThreads(); QStringList files; QVector<ReportType> reports; //  signals: void stopAll(); //   };

कक्षा में सबसे महत्वपूर्ण विधि: addThread

 void Session::addThread(ReportType r_type) { RBWorker* worker = new RBWorker(r_type); QThread* thread = new QThread; worker->setFileList(files); /*      */ worker->moveToThread(thread); /*     . : */ connect(thread, SIGNAL(started()), worker, SLOT(process())); /* …        process(),    ,       : */ connect(worker, SIGNAL(finished()), thread, SLOT(quit())); /* …      ,      finished() ,    quit() : */ connect(this, SIGNAL(stopAll()), worker, SLOT(stop())); /* …  Session         ,         finished()  : */ connect(worker, SIGNAL(finished()), worker, SLOT(deleteLater())); /* …           : */ connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater())); /* …      ,    .        .   : */ thread->start(); /*  ,   RBWorker::process(),   ReportBuilder     */ return ; } void Session::stopThreads() /*     */ { emit stopAll(); /*  RBWorker   ,        quit()   */ } void Session::buildReports() { stopThreads(); for(int i =0; i < reports.size(); ++i) { addThread(reports.at(i)); } return ; } void Session::~Session() { stopThreads(); /*         */ … }

व्यवहार में, सब कुछ लगभग तुरंत काम किया। बहुत धन्यवाद माया पॉश - यह पता लगाने में मदद की।

क्यूथ्रेड का उचित उपयोग

कार्य

Qt प्रलेखन उदाहरण: गलत

कैसे करें?

More articles: