सरल PHP मल्टीथ्रेडिंग कार्यान्वयन

PHP में मल्टीथ्रेडिंग "बॉक्स से बाहर" अनुपस्थित है, इसलिए इसके कार्यान्वयन के लिए कई बेहतरीन विकल्पों का आविष्कार किया गया था, जिसमें एक्सटेंशन pthreads , AzaThread (CThread), और यहां तक ​​कि कुछ PHP डेवलपर्स के स्वयं के विकास भी शामिल हैं।

इन समाधानों के लिए मेरे लिए मुख्य नुकसान बहुत सारे "घंटियाँ और सीटी" थे - हमेशा थ्रेड और मूल प्रक्रिया के बीच या संसाधनों को बचाने के लिए जानकारी के आदान-प्रदान की आवश्यकता नहीं होती है। समस्या को जल्दी और लागत प्रभावी ढंग से हल करने की क्षमता हमेशा होनी चाहिए।

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

इसलिए, कार्य बड़ी मात्रा में डेटा को संसाधित करना है जो हमारी स्क्रिप्ट में आया है। मेरा काम पाठ्य सूचनाओं के JSON सरणी को संसाधित करना था, जिसे पचाने के लिए स्क्रिप्ट को पोस्टग्रॉक्सीक्यूएल के लिए समान रूप से बड़ी प्रतिबद्धता से इकट्ठा करना था।

सबसे पहले, हम मूल फ़ाइल में डेटा एकत्र करते हैं:

index.php

// bigdata.json -    .      - ,     .. $big_json = file_get_contents('bigdata.json'); $items = json_decode($big_json, true); //   php    ,    , ,  unset($big_json); // ... 

सरणी आकार में 400mb के आसपास उतार-चढ़ाव हुआ (बाद में इसे घटाकर ~ 50mb कर दिया गया), और सभी जानकारी शाब्दिक थी। उस गति का अनुमान लगाना मुश्किल नहीं है जिसके साथ यह सब पच गया था, और यह देखते हुए कि स्क्रिप्ट हर 15 मिनट में क्रोन पर चलाई गई थी, और कंप्यूटिंग शक्ति इतनी अधिक थी - प्रदर्शन को बहुत नुकसान हुआ।

डेटा प्राप्त करने के बाद, आप उनकी मात्रा का अनुमान लगा सकते हैं और यदि आवश्यक हो, प्रत्येक सीपीयू कोर के लिए थ्रेड्स की आवश्यक संख्या की गणना करें, या आप बस यह तय कर सकते हैं कि 4 थ्रेड होंगे और प्रत्येक थ्रेड के लिए पंक्तियों की संख्या की गणना करें:

index.php

  // ... $threads = 4; $strs_per_thread = ceil(count($items) / $threads); //      -   echo "Items: ".count($items)."\n"; echo "Items per thread: ".$strs_per_thread."\n"; echo "Threads: ".$threads."\n"; // ... 

यह तुरंत ध्यान देने योग्य है - इस तरह के "हेड-ऑन" गणना प्रत्येक स्ट्रीम के लिए तत्वों की संख्या द्वारा सटीक परिणाम नहीं देगी। गणनाओं को सरल बनाने की अधिक संभावना है।

और अब बहुत सार - हम प्रत्येक थ्रेड के लिए कार्य बनाते हैं और इसे चलाते हैं। हम इसे "माथे" करेंगे - दूसरी फ़ाइल के लिए एक कार्य बनाना - थ्रेड। एफपी। यह एक "स्ट्रीम" के रूप में कार्य करेगा, मुख्य स्क्रिप्ट के प्रसंस्करण और स्वतंत्र रूप से शुरू करने के लिए तत्वों की एक सीमा प्राप्त करेगा:

index.php

  // ... for($i = 0; $i < $threads; $i++){ if($i == 0) { passthru("(php -f thread.php 0 ".$strs_per_thread." & ) >> /dev/null 2>&1"); } if($i == $threads-1) { passthru("(php -f thread.php ".($strs_per_thread * $i)." ".count($items)." & ) >> /dev/null 2>&1"); } if(($i !== 0)&&($i !== $threads-1)) { $start = $strs_per_thread * $i + 1; $end = $start -1 + $strs_per_thread; passthru("(php -f thread.php ".$start." ".$end." & ) >> /dev/null 2>&1"); } } // ... 

पसस्ट्रु () फ़ंक्शन का उपयोग कंसोल कमांड चलाने के लिए किया जाता है, लेकिन स्क्रिप्ट उनमें से प्रत्येक को पूरा करने के लिए इंतजार करेगी। ऐसा करने के लिए, हम लॉन्च कमांड को ऐसे बयानों के सेट में लपेटते हैं जो प्रक्रिया शुरू करेंगे और तुरंत कुछ भी नहीं लौटाएंगे, प्रक्रिया शुरू करने और मूल प्रक्रिया प्रत्येक बच्चे को निष्पादित करने के लिए इंतजार करना बंद नहीं करेगी:

 #  ,    ,   Linux- (php -f thread.php start stop & ) >> /dev/null 2>&1 

वास्तव में यहाँ क्या हो रहा है, दुर्भाग्य से, मैं निश्चित रूप से नहीं कह सकता - मेरे परिचित लिनक्सॉइड द्वारा मुझे मापदंडों का एक सेट सुझाया गया था। यदि आप टिप्पणियों में इस जादू को समझ सकते हैं, तो मैं आभारी रहूंगा और पोस्ट को पूरक करूंगा।

फ़ाइल थ्रेड। Php:

 $start = $argv[1]; $stop = $argv[2]; for ($i = $start; $i <= $stop; $i++) { // -          } 

इसमें, काफी सरल, तरीका, आप PHP में मल्टीथ्रेडिंग एमुलेशन लागू कर सकते हैं।

यदि हम आउटपुट को सुखाने के लिए पूरे उदाहरण को कम करते हैं, तो मुझे लगता है कि यह इस तरह से ध्वनि करेगा: कमांड लाइन के माध्यम से माता-पिता का थ्रेड चाइल्ड प्रोसेस लॉन्च करता है, उन्हें बताता है कि क्या प्रक्रिया है।

जब मैं "एमुलेशन" कहता हूं, तो मेरा मतलब है कि इस कार्यान्वयन विधि के साथ थ्रेड्स के बीच या माता-पिता और बच्चे के थ्रेड्स के बीच जानकारी का आदान-प्रदान करने का कोई तरीका नहीं है। यह उपयुक्त है अगर यह पहले से जाना जाता है कि ऐसी सुविधाओं की आवश्यकता नहीं है।