multithreading - Ruby - Using a Mutex to keep threads from stopping prematurely -

-

I am writing a Ruby application (Ruby v2.1.3p242 x86_64 in Linux) which will repeatedly process online data and To store things in a database, I have multiple threads running simultaneously and I am working to stop all threads at command and completely while lifting exceptions from a thread.

The issue is that some threads will continue to run many code after the #do_stuff which is said after the saver.stop . After all, they are closed, but after the rest are closed I see some thread going 10-50 times.

Each threads' Mute X is locked before each recurrence and unlocks later. Code, @ mutex.synchronize {kill} is running on every thread when called server.stop . This should kill the thread immediately after its next recurrence, but it does not seem like this.

Edit:

works as a code, so if you wish, do not hesitate to test it. In my tests, after calling server.stop 30 seconds and several minutes to stop all threads, note that each transfer takes between 1-3 seconds. I used the following to test the code (in the same directory while using Ruby-I. ): 

  requires 'benchmark' The 'server' = Server puts the new s.start benchmark. Measure {s.stop}

Here is the code:

server.rb:

Requires a class of server / fiber_thread class; Server Thread = 8 Entry_Reader: Start Thread Def start @ threads = [] and start def create_threads end def stop @ threads.map {| T | Thread.new {t.stop}} .each (more: join) @ threads = [] end personalized def _ threads THREADS.times do | I | @ Threads & lt; & Lt; FetcherThread.new (number: i + 1) end-end

server / fetcher_thread.rb: 

  class server class FetcherThread & lt; Thread attr_reader: mutex def initialize (opts = {}) @mutex = mute x.new @number = opts [: number] || 0 Super Do Loop do @ mutex.synchronize {do_stuff} End end def def @ mutex.synchronize {kill} End personal def do_stuff debugging "# {time_to_sleep = rand * 2 + 1} sleeping for seconds" sleep time_to_sleeps end Def debug (message) $ stderr.print "thread ## {@ number}: # {message} \ n" end and end

There is no guarantee that the thread will receive the mute before the next recurrence of the call stop loop. It is fully up to Ruby and operating system scheduling, and some OS () do not implement a FIFO scheduling algorithm, but keep in mind other factors to optimize performance.

You can estimate it more to avoid the kill and by using a variable to exit the loop cleanly, then you can only copy the code Around the mute x must be wrapped, which is the variable 

  class server class FetcherThread & lt; Thread attr_reader: mutex def initialize (opts = {}) @mutex = mute x.new @number = opts [: number] || 0 Until the super stop? Do_stuff end end end def mutex.synchronize {@stop = true} end DEF stopped? Mutex.synchronize {@stop} end # ... and end

Comments

Post a Comment

Popular posts from this blog

c# - SignalR: "Protocol error: Unknown transport." when navigating to hub -

-
Image
I am trying to use the ASP.NET signal for the first time - here's what I did: created a new web Has been added to the project and the following signal R packages: I have created the following category: [Hub-name ("chat")] Public class ChatHub: Hub {Public Zero Halo () {Clients.All.hello ( ); }} and the following startup configuration: public partial class startup {public zero configuration (IAppBuilder app) {configure (app); App.MapSignalR (); }} However, whenever I navigate localhost: (port) / api / signalr / chat I get the following error: Protocol error: Unknown transport. I am running a new browser and trying different people so remove it from the API / URL, and just use the localhost: (potter) / signaller / Chat
Read more

class - Kivy: how to instantiate a dynamic classes in python -

-
Using KV lang on my Python code, I have taken a hard time trying to instantiate a dynamic class, the following Consider the code: My test.kv file looks like this: & lt; MyPopup @ popup: Title: 'Hello' size_hunt: (1, .6) Grid layout: ID: RouteGrid column: 2 padding: ['8dp', '4dp', '8dp', '4dp'] Difference: '8dp' label: text: 'some text here' button: text: 'OK' On_press: do_something () & lt; MyGrid & gt;: Rows: 1 Button: Text: 'Show Popup' on_press: root.pop.show () Then import Kivy.app into my test.py: I get the following error: raise Factory Exception ('Uncount Class' '% name) kivy.factory.FactoryException: Unknown class Can anyone tell me how to do this properly, what do I remember? If you need more information please let me know Thank you. Takes a call to the factory before the KV file is loaded, so you want the class to Are not yet in existence. As long as no clas...
Read more

Registering an Interceptor For All Interface Implementaions in Castle Windsor -

-
I'm quite new to the castle and especially to the Windsor using Interceptors and if it's all across a It is possible to register the interceptor, in return, instead of specifying each implementation, implementing a particular interface. For example, I have an interface called IComponent , which will be implemented by multiple classes. I have a ComponentInterceptor class written to work on these classes when they have performed a particular method, I want to do something like this: _container Register (Component.For & LT; IComponent & gt; () .Interceptors ("ComponentInterceptor") .LifestyleSingleton ()) Rather than what to do: _container.register (Component.For & lt; IComponent & gt; (). ImplementedBy & lt; Componenta & gt; () .Interceptors ("ComponentInterceptor") .LifestyleSingleton ()), _container.Register (Component . & Lt; IComponent & gt; (.) ImplementedBy & LT; ComponentB & gt; () .Interceptors (...
Read more