Ruby - async_fu, easy to use threads

I’ve been working with ruby ​​for a while but almost in the first days there was an urgent need to run long-playing functions that should not block the operation of the main program.

I did not find a ready-made and simple solution, therefore I began to reinvent the wheel.

At the moment, the library allows:

• organize asynchronous calls to your class methods
• guarantees the execution of all threads before exiting the program

Example of use:

Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello

1. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
2. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
3. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
4. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
5. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
6. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
7. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
8. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
9. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
11. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello
12. Copy Source | Copy HTML class YourClass1 def hello p 'start' p 'list ' + Thread .list.join( ' ' ) p 'main ' + Thread .main.to_s p 'this ' + Thread .current.to_s p 'end' end end af = AsyncFu. new ( YourClass1 .new) af. hello

Copy Source | Copy HTML

1. class YourClass2 <AsyncFu
2. def hello
3. p 'start'
4. p 'list' + Thread .list.join ( '' )
5. p 'main' + Thread .main.to_s
6. p 'this' + Thread .current.to_s
7. p 'end'
8. end
9. end
11. ai = YourClass2 .new
12. ai. hello

Feel free here: GitHub
')
Todo

• Make sane callback, so you can track the status.
• Make exception handling and return statuses.
• Make it possible to use the mixin style.

PS It is interesting to listen to the guru :)

UPD
The above examples, there is no way to use it, this is a test of threads, a piece of old dough.
In fact, you can do this:

Copy Source | Copy HTML

1. require 'rubygems'
2. require 'async_fu'
4. class some
5. def grep (query, path)
6. list = ` grep -rne '# {query}' # {path}`
7. File . new ( '/tmp/grep.log' , 'w' ) .write list
8. end
9. def tick
10. loop {
11. sleep 1
12. p 'tick'
13. }
14. end
15. def tack
16. loop {
17. sleep 2
18. p 'tack'
19. }
20. end
21. end
23. test = AsyncFu. new ( Some .new)
24. test. tick
25. test. grep ( 'thread.rb' , '/ usr / local / lib' )
26. test. tack