Threaded classes

[Martin Leduc]

Good day,

I'm beginner into the Java Thread Programming and I've read many hours on the subject without found my issue. I hope somebody can help me. My problem is: what is the best way to create non synchronised and non-blocking threads. Per example.

I have a short class A who I need access to his Getter. So i defined

public class class_A extends Thread
{ 
      private boolean bol_StopThread = false;
      public void run()
      {
          bol_StopThread =false;
          while (!bol_StopThread)
          {
                //BLABLALBA
               System.out.println("HEART BEAT");
               Thread.sleep(1000);
          }
      }


      public void StopThread()
      {
          bol_StopThread = true
          return;
      }
}

I defined a class thread container

public class ThreadContainer{

    static Map<String,class_A> obj_ThreadContainer = new ConcurrentHashMap<String,class_A>();

    public void main()
    {
        obj_ThreadContainer.put("TH_1",new class_A());
        obj_ThreadContainer.put("TH_2",new class_A());

        obj_ThreadContainer.get("TH_1").start();
        obj_ThreadContainer.get("TH_2").start();

       while(something to die)
       {
            /* WHILE System.in.readLine() implementation */
            
       }
    }
}

My reader need to read until the readLine() = true but that's still block the while of my two others threads. I have to press severals <ENTER> to unlock my other threads and execute their loop. By reading the Oracle Java Doc API, the object ConcurrentHashMap aren't a blockable object queue.

A hash table supporting full concurrency of retrievals and adjustable expected concurrency for updates. This class obeys the same functional specification as Hashtable, and includes versions of methods corresponding to each method of Hashtable. However, even though all operations are thread-safe, retrieval operations do not entail locking, and there is not any support for locking the entire table in a way that prevents all access. This class is fully interoperable with Hashtable in programs that rely on its thread safety but not on its synchronization details.

The best world IS HAVING my two Class_A can return a value into a LinkedQueue and the queued element are care by the ThreadContainer.

Like:

    //LQ_n  defined a LinkedQueue object.  Why LinkedQueue??  The remove method to clean the stack???
    while(!something_to_rip)
    {
          if(something to do with LQ_TH1)
          if(something to do with LQ_TH2)
          if(some command to read from LQ_Reader)
   }

Mabe I made something wrong, dont use the correct class/object or simply have to run my class_C4(destruct_my_brain).run()

No seriously, I realy need help. I'm completely upsets and will very soon turn this project in C++ ;) but I need the Java portability so...

Thanks in advanced

Martin L.

[Keith Rainey]

   while(something to die)   
       {   
            /* WHILE System.in.readLine() implementation */  
               
       }  

I assume that this section of code is running in such a tight loop that the main thread never yields to allow the other two threads to run. Throw a Thread.sleep(100) in the loop and see if that affects your outcome.

[Martin Leduc]

For your information, this is my Reader Run Thread method.

Can we add a king of Timeout to the Readline() method???

Regards

Martin

    public void run()
	{
    	BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));
    	
		String str_LastCommand="";
		while(bol_Stop==false)
		{
		    
			String str_Commandline="";
			try {
				str_Commandline = bufferedReader.readLine();
                                          if (str_Commandline.length()>0)
				{
					if(str_Commandline.contentEquals(".")){
						str_Commandline=str_LastCommand;
					}
					str_LastCommand = str_Commandline;
					obj_CommandQueue.add(str_Commandline);
				}
			}catch (IOException e){
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
   		System.out.println("READER THREAD STOPPED");
	}