कौन सा आर्किटेक्चर या डिज़ाइन पैटर्न इस एप्लिकेशन के लिए उपयुक्त हैं?

Question

मैं विभिन्न कोरों में एक ही समय में एकाधिक इनपुट को संसाधित करने के लिए सी ++ में एक एप्लिकेशन बनाने के लिए एक आर्किटेक्चर के लिए शोध कर रहा हूं। प्रत्येक इनपुट एक साथ एक कोर में संसाधित किया जाता है। कोर पर प्रत्येक प्रक्रिया, एक ही फ़िल्टर के माध्यम से संसाधित किया जाएगा। उदाहरण के लिए: filter1.apply(), filter2.apply() और filter3.apply()। प्रक्रियाओं नीचे के रूप में 4 आदानों के लिए 4 कोर के लिए दर्शाए गए हैं:

 
[core 1] [core 2] [core 3] [core 4] 
    |   |   |   |  
    V   V   V   V 
    input1  input2  input3  input4 
    |   |   |   |  
    V   V   V   V 
filter1 filter1  filter1 filter1 
    |   |   |   |  
    V   V   V   V 
filter2 filter2  filter2 filter2 
    |   |   |   |  
    V   V   V   V 
filter3 filter3  filter3 filter3 
    |   |   |   |  
    V   V   V   V 
output1 output2  output3 output4 

मैं जानता हूँ कि जो वास्तुकला या डिजाइन पैटर्न इस के लिए उपयुक्त है न। अगर आप मुझे कुछ और कलाकृतियों (दस्तावेज़ या नमूना आवेदन) को आगे पढ़ने के लिए देते हैं तो यह बहुत अच्छा होगा।

अग्रिम धन्यवाद।

Answer 1

आमतौर पर ऐसे डिज़ाइन को लागू करने के लिए थ्रेड पूल का उपयोग किया जाता है। वे स्वतंत्र प्रक्रियाओं के लिए लगभग असीम पैमाने पर स्केल करते हैं। आप टीबीबी और पीपीएल में आसान कार्यान्वयन पा सकते हैं। वे कई मानक एल्गोरिदम और कंटेनरों के समवर्ती-संबंधित संस्करण प्रदान करते हैं। उदाहरण के लिए, इस नमूने में मैंने concurrent_vector का उपयोग किया है, जो एक vector-जैसी कंटेनर है जिसे कई धागे से सुरक्षित रूप से उत्परिवर्तित किया जा सकता है, और parallel_for_each, जो एक साथ कई धागे पर फ़ंक्शन चलाता है।

concurrent_vector<output> outputs; 
std::vector<input> inputs; 
parallel_for_each(inputs.begin(), inputs.end(), [](input& input) { 
    outputs.push_back(filter3(filter2(filter1(input)))); 
}); 

Answer 2

मुझे लगता है कि "रणनीति विधि" सहायक है। प्रत्येक कोर में, एक सदिश को एक वस्तु के रूप में प्रत्येक फिल्टर डालता है जैसे:

std::vector<filter> filters; 

तो

std::for_each(filters.begin(), filters.end(), [input&](f&){f.apply(input);}); 

================== ==

हम फ़िल्टर द्वारा पुन: इनपुट करते हैं, इनपुट नहीं। तो हम रनटाइम पर/डेल फ़िल्टर जोड़ सकते हैं।

की तरह:

class YourCore { 
public: 
    void add_filter(const filter& f) {m_filters.add(f);} 
    // void del_filter(int index); 
    // void del_filter(by name or UID, so change vector to map or unordered_map); 
private: 
    std::vector<filter> m_filters; 
};