c# - Thread queues for dummies -


I think what I think is a very common threading scenario:

  • I have 100 similarities
  • All jobs are independent of each other
  • I want to process up to 15 jobs at a time
  • Every task is completed However, the job will be started until all new jobs are completed

If you believe that every action will set an event to fire, It will be completed (I am using background worker classes), I can think of a couple ways of closing it, but I'm not sure what the "right" solution was, I was hoping that Some of you guru can point me in the right direction from there.

Solution 1: one while (continued) {threading. Sleep (1000); } Loop in my main () function. The code will be continued in the Job_Completed event handler = false when A) any work should not be queued and B) all the queued tasks have been completed I used this solution earlier And when it works fine ... it seems a bit awkward for me.

Solution 2: Use the application.Run () My Man () function will similarly call the code application in the Job_Completed event handler. No queue queue and B) all queued works are complete when the exit () is A) .

Solution 3: Use Threadpool, line up all 500-1000 requests, run them at a time (setmaxtrared) and wait for them to complete anyway Please.

In all these solutions, the basic idea is that each other job will be completed every time, unless no jobs are left. Therefore, the problem is not only waiting for the completion of existing jobs, but also wait till there is no pending job to start. If Thunderpool is the right solution, then what is the correct way to wait for Threadpool to complete all the queued items?

I think my overriding illusion here is that I did not understand how incidents happen in the fire, apparently from within my main () function, I have a Windows message loop The point-of-view does not understand the mechanic. What is the right way to resolve this problem, and why?

Even if other answers are good you want another option (you never get enough options ), Then how to think about it as an idea.

Just enter the data in a structure for each task, which is in the FIFO stack.

Create 15 threads.

Each thread will get the next job from the stack, press it.

When a thread finishes processing, get the next job, if the stack is empty, the thread dies or just sleeps, waiting.

The only complexity, which is very easy to solve, popping is happening in an important segment (read / pop synchronize).


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