1   package eu.fbk.knowledgestore.populator.naf;
2   import java.io.IOException;
3   import java.io.Writer;
4   import java.util.Hashtable;
5   import java.util.concurrent.BlockingQueue;
6   
7   import org.slf4j.Logger;
8   
9   public class Producer implements Runnable {
10   
11      static BlockingQueue<Hashtable<String, KSPresentation>> queue;
12       
13      public Producer(BlockingQueue<Hashtable<String, KSPresentation>> q){
14          this.queue=q;
15      }
16      
17      @Override
18      public void run() {
19          //produce messages
20              NAFRunner msg = new NAFRunner();
21                  msg.generate();
22                 // Thread.sleep(i);
23                  //queue.put(msg);
24                  //System.out.println("Produced "+msg.getMsg());
25             
26          
27      }
28      
29      
30   
31  }