Ruby多线程例子

    很久不写了，发一个最近的ruby多线程例子，没有线程同步问题，比较简单。

1. require 'json'
2. require 'rest-client'
3. require 'thread'
5. $contenct=[]
8. def get_metrics
9. get_json($content).select do |item|
10. if /^opentsdb/ =~ item
11. item
12. end
13. end
14. end
16. def batch_request(thread_index, items, result)
17. tmp = []
19. items.each_with_index do |item, index|
20. begin
21. res = JSON.parse(RestClient.get "http://opentsdb.xxx.com/api/query?start=1w-ago&m=sum:1w-max:#{item}")
22. rescue
23. retry
24. end
26. puts "thread-#{thread_index}: #{index}:#{item}:#{res.size != 0}"
27. tmp << "#{item},#{res.size != 0}"
28. end
29. result << tmp
30. end
32. def main
33. metrics = get_metrics
35. puts '*' * 144
36. puts metrics.size
38. groups = metrics.each_slice(400).to_a
40. thread_jobs = []
41. results = []
42. groups.each_with_index do |items, index|
43. thread_jobs << Thread.new { batch_request(index, items, results) }
44. end
46. thread_jobs.each { |thread| thread.join }
48. puts '#' * 144
49. records = 0
51. open('data.csv', 'w+') do |file|
52. results.each do |items|
53. records += items.size
54. items.each do |item|
55. file << item + "\n"
56. end
57. end
59. puts records
60. end
63. puts 'done'
65. end
67. main