Revert "Refactoring on worker threads."

This reverts commit 7f5c257.

Author: laliux

app/app.py

@@ -38,41 +38,43 @@ def main():
         logger.info("No configured markets, using all available on exchange.")
         market_data = exchange_interface.get_exchange_markets()
 
+#    notifier = Notifier(config.notifiers, market_data)
+
     thread_list = []
 
     for exchange in market_data:
-        for key in market_data[exchange].keys():
-
+        num = 1
+        for chunk in split_market_data(market_data[exchange]):
             market_data_chunk = dict()
-            market_data_chunk[exchange] = {key : market_data[exchange][key]}
-
-            workerName = "Worker-{}-{}".format(exchange, key)
+            market_data_chunk[exchange] = { key: market_data[exchange][key] for key in chunk }
 
             notifier = Notifier(config.notifiers, config.indicators, market_data_chunk)
-            behaviour = Behaviour(config, exchange_interface, notifier)            
-            
+            behaviour = Behaviour(config, exchange_interface, notifier)
+
+            workerName = "Worker-{}".format(num)
             worker = AnalysisWorker(workerName, behaviour, notifier, market_data_chunk, settings, logger)
             thread_list.append(worker)
             worker.daemon = True
             worker.start()
-            time.sleep(2)
-    
+
+            time.sleep(60)
+            num += 1
+
     logger.info('All workers are running!')
 
     for worker in thread_list:
         worker.join()
 
-"""
 def split_market_data(market_data):
     if len(market_data.keys()) > 20:
         return list(chunks(list(market_data.keys()), 20))
     else:
         return [list(market_data.keys())]
 
 def chunks(l, n):
+    """Yield successive n-sized chunks from l."""
     for i in range(0, len(l), n):
         yield l[i:i + n]
-"""
 
 class AnalysisWorker(Thread):