Բազմահոսքայնությունը Java-ում

class WikiThread implements Runnable {
    private Thread t;
    private String threadName;
 
    WikiThread(String name) {
        threadName = name;
        System.out.println("Creating " + threadName );
    }
 
    public void run() {
        System.out.println("Running " + threadName );
        try {
            for(int i = 4; i > 0; --i) {
                System.out.println("Thread: " + threadName + ", " + i);
                Thread.sleep(50);
            }
        }
        catch (InterruptedException e) {}
 
        System.out.println("Thread " + threadName + " exiting.");
    }
 
    public void start() {
        System.out.println("Starting " + threadName );
        if (t == null) {
            t = new Thread (this, threadName);
            t.start();
        }
    }
}

public class Wiki {
    public static void main(String[] args) {
        WikiThread R1 = new WikiThread("Thread-1");
        R1.start();
 
        WikiThread R2 = new WikiThread("Thread-2");
        R2.start();
    } 
}

class ThreadDemo extends Thread {
    private Thread t;
    private String threadName;
 
    ThreadDemo( String name) {
        threadName = name;
        System.out.println("Creating " + threadName );
    }
  
    public void run() {
        System.out.println("Running " + threadName );
        try {
            for(int i = 4; i > 0; ––i) {
                System.out.println("Thread: " + threadName + ", " + i);
                Thread.sleep(50);
            }
        }

        catch (InterruptedException e) {
            System.out.println("Thread " + threadName + " interrupted.");
        }
 
        System.out.println("Thread " + threadName + " exiting.");
    }
 
    public void start() {
       System.out.println("Starting " + threadName );
       if (t == null) {
           t = new Thread (this, threadName);
           t.start();
       }
    }
}

public class WikiThread {
    public static void main(String args[]) { 
        ThreadDemo T1 = new ThreadDemo("Thread-1");
        T1.start();
 
        ThreadDemo T2 = new ThreadDemo("Thread-2");
        T2.start();
    } 
}

class RunnableThread implements Runnable {
    @Override
    public void run() {
        try {
            System.out.println("Runnable Thread:"+Thread.currentThread().getName());
            Thread.sleep(5000);
        }
        catch (InterruptedException e) {
            System.out.println(e.getMessage());
        }
    }
}

public static void main(String[] args) {
    Thread t1 = new Thread(new RunnableThread());
    Thread t2 = new Thread(new RunnableThread());
    SingleThread t3 = new SingleThread();

    t1.start();
    t2.start();
    try {
        t2.join();
    }
    catch (InterruptedException e) {
        System.out.println(e.getMessage());
    }
    t3.start();
}

currentThread = null;

Thread.sleep(5000);

//առանց սինխրոնիզացիա
class PrintDemo {
   public void printCount(){
    try {
         for(int i = 5; i > 0; i--) {
            System.out.println("Counter   ---   "  + i );
         }
     } catch (Exception e) {
         System.out.println("Thread  interrupted.");
     }
   }
}

class ThreadDemo extends Thread {
   private Thread t;
   private String threadName;
   PrintDemo  PD;

   ThreadDemo( String name,  PrintDemo pd){
       threadName = name;
        PD = pd;
   }
   public void run() {
     PD.printCount();
     System.out.println("Thread " +  threadName + " exiting.");
   }

   public void start ()
   {
      System.out.println("Starting " +  threadName );
      if (t == null)
      {
         t = new Thread (this, threadName);
         t.start ();
      }
   }
}

public class TestThread {
   public static void main(String args[]) {

      PrintDemo PD = new PrintDemo();

      ThreadDemo T1 = new ThreadDemo( "Thread - 1 ", PD );
      ThreadDemo T2 = new ThreadDemo( "Thread - 2 ", PD );

      T1.start();
      T2.start();

      // wait for threads to end
      try {
         T1.join();
         T2.join();
      } catch( Exception e) {
         System.out.println("Interrupted");
      }
   }
}

//սինխրոնիզացիայով

class PrintDemo {
   public void printCount(){
    try {
         for(int i = 5; i > 0; i--) {
            System.out.println("Counter   ---   "  + i );
         }
     } catch (Exception e) {
         System.out.println("Thread  interrupted.");
     }
   }

}

class ThreadDemo extends Thread {
   private Thread t;
   private String threadName;
   PrintDemo  PD;

   ThreadDemo( String name,  PrintDemo pd){
       threadName = name;
       PD = pd;
   }
   public void run() {
     synchronized(PD) {
        PD.printCount();
     }
     System.out.println("Thread " +  threadName + " exiting.");
   }

   public void start ()
   {
      System.out.println("Starting " +  threadName );
      if (t == null)
      {
         t = new Thread (this, threadName);
         t.start ();
      }
   }

}

public class TestThread {
   public static void main(String args[]) {

      PrintDemo PD = new PrintDemo();

      ThreadDemo T1 = new ThreadDemo( "Thread - 1 ", PD );
      ThreadDemo T2 = new ThreadDemo( "Thread - 2 ", PD );

      T1.start();
      T2.start();

      // wait for threads to end
      try {
         T1.join();
         T2.join();
      } catch( Exception e) {
         System.out.println("Interrupted");
      }
   }
}