multithreading - Threaded implementation of observer pattern - C++ -


I am developing a C ++ program that has a "scan" method that has long been running the scanning process Will speed up. When the process is completed, the scan method will inform the supervisors of the results using the supervisor pattern.

I want to make a separate thread for each scan. In this way, I can run many scans together when each scanning process is completed, then I would like the scan method to inform the listeners.

According to the Boost Thread Library, it seems that I can do something like this: 

  #include & lt; Boost / thread / thread.hpp & gt; # Include & lt; Boost / thread / mutex.hpp & gt; # Include & lt; Boost / bind.hpp & gt; # Include & lt; Iostream & gt; Boost: Mute x io_mutex; Zero scan (int scan _ target, vector & lt; lister; listeners) {//..run scan (boost :: mutex :: scoped_lock lock (io_mutex); std :: cout & lt; "end scan" & Lt; endl; // Notify the listeners by going through the vector again and "notify ()}} the main points (int argc, char * argv []) and {vector & lt; audience / listeners // boost :: thread thrd1 (boost :: bind) (and scan, 1, listeners)); Promotion :: thread thrd2 (boost :: bind (and scan, 2, listeners)); //thrd1.join ( ); //thrd2.join (); Returns 0;}

Does this look almost right? Do I need to call listeners? Is it OK to get rid of joining?

You Whether the lock is required or not, it depends on you what you do with the notification. I think that if you lock the function to only those listeners where you need a single threaded access.

< / Div>

Comments

Post a Comment

Popular posts from this blog

python - Overriding the save method in Django ModelForm -

I'm having trouble overriding a ModelForm save method. I get this error I'm: Exception type: TypeErier Exception Value: Save () found an unexpected keyword argument 'committed' My intentions include a form 3 fields Submit several values ​​for, then create an object for each combination of those areas, and to save each object file models.py class collarsult type (models.Model): id = model. AutoField (db_column = 'icontact_result_code_type_id', primary_key = true) callResult = models.ForeignKey ( 'CallResult', db_column = 'icontact_result_code_id') campaign = models.ForeignKey ( 'campaign', db_column = 'icampaign_id') CALLTYPE = models.ForeignKey ( 'CALLTYPE', db_column = 'icall_type_id') agent = models.BooleanField (db_column = 'bagent', default = true) teamLeader = models.BooleanField (db_column = 'bTeamLeader', default = true) active = models.BooleanField (db_column = Django.form...
Read more

html - CSS autoheight, but fit content to height of div -

I have a div in which there are three children- div in the left and middle div: float: left while true: float: true because it is my layout Actually will spoil, I've used ClearFix Hack: .cf {zoom: 1; }. Cf: First,. Cf: {content: ""; Display: Table; }. Cf: After {clear: both; } It still works, but I want to be the right div an indicator. So it should fill 100% of the parent unit of height. How can I complete this? PS is the full code: & Lt; / Div & gt; & Lt; Div class = "mobile_content" & gt; & Lt; H5 & gt; {{Data.titel}} & lt; / H5> & Lt; Table & gt; & Lt; TR & gt; & Lt; Th & gt; Komponist: & lt; / Th & gt; & Lt; TD & gt; {{Data.komponist}} & lt; / TD & gt; & Lt; / TR & gt; & Lt; TR & gt; & Lt; Th & gt; Instrument: & lt; / Th & gt; & Lt; TD & gt; {{Data.instrumente}} & lt; / TD & gt; & Lt; / TR & gt;...
Read more

qt - How to prevent QAudioInput from automatically boosting the master volume to 100%? -

I have been trying to use Qt5 multimedia to record audio with QAudioInput, however, when I see If QAudioInput is started, it increases the master volume of my sound device to 100%. How can I prevent QAudioInput from changing the master volume? My current development platform is Linux with PalsAdio (with flat audio disabled). How can I use QAudioInput : QAudioDeviceInfo device_info = QAudioDeviceInfo :: defaultInputDevice (); QAudio format format; Format.setSampleRate (44100); Format.setChannelCount (1); Format.setSampleSize (16); Format.setCodec ("Audio / PCM"); Format.setSampleType (QAudioFormat :: SignedInt); Format.setByteOrder (QAudioFormat :: LittleEndian); Std :: cout & lt; & Lt; Device_info.deviceName (). ToUtf8 (). ConstData () & lt; & Lt; Std :: endl; QAudioInput * default_device = new QAudioInput (device_info, format); QIODevice * default_io_device = default_device-> Start (); a QAudioInput.setVolume () method is not you I ...
Read more