Implementation of Mutual Exclusion

Implementation of Mutual Exclusion

A) Centralized
B) Distributed
C) Token Ring

Code:

EchoClientOne.java

import java.io.*;
import java.net.*;

public class EchoClientOne
{
    public static void main(String args[])throws IOException
    {
        Socket s=new Socket("localhost",7000);
        PrintStream out = new PrintStream(s.getOutputStream());
       
        ServerSocket ss = new ServerSocket(7001);
        Socket s1 = ss.accept();
        BufferedReader in1 = new BufferedReader(new
InputStreamReader(s1.getInputStream()));
        PrintStream out1 = new PrintStream(s1.getOutputStream());
        BufferedReader br = new BufferedReader(new
InputStreamReader(System.in));
        String str="Token";
        while(true)
        {
            if(str.equalsIgnoreCase("Token"))
            {
                System.out.println("Do you want to send some data");
                System.out.println("Enter Yes or No");
                str=br.readLine();
                if(str.equalsIgnoreCase("Yes"))
                {
                    System.out.println("Enter the data");
                    str=br.readLine();
                    out.println(str);
                }
                out1.println("Token");
            }
            System.out.println("Waiting for Token");
            str=in1.readLine();
        }
    }
}

EchoClientTwo.java

import java.io.*;
import java.net.*;

public class EchoClientTwo
{
    public static void main(String args[])throws IOException
    {
        Socket s=new Socket("localhost",7000);
        PrintStream out = new PrintStream(s.getOutputStream());

        Socket s2=new Socket("localhost",7001);
        BufferedReader in2 = new BufferedReader(new
InputStreamReader(s2.getInputStream()));
        PrintStream out2 = new PrintStream(s2.getOutputStream());
        BufferedReader br = new BufferedReader(new
InputStreamReader(System.in));
        String str;
        while(true)
        {
            System.out.println("Waiting for Token");
            str=in2.readLine();
            if(str.equalsIgnoreCase("Token"))
            {
                System.out.println("Do you want to send some data");
                System.out.println("Enter Yes or No");
                str=br.readLine();
                if(str.equalsIgnoreCase("Yes"))
                {
                    System.out.println("Enter the data");
                    str=br.readLine();
                    out.println(str);
                }
                out2.println("Token");
            }
        }
    }
}

EchoServer.java

import java.io.*;
import java.net.*;

public class EchoServer implements Runnable
{
    Socket socket=null;
    static ServerSocket ss;
    EchoServer(Socket newSocket)
    {
        this.socket=newSocket;       
    }
    public static void main(String args[]) throws IOException
    {
        ss=new ServerSocket(7000);
        System.out.println("Server Started");
        while(true)
        {
            Socket s = ss.accept();
            EchoServer es = new EchoServer(s);
            Thread t = new Thread(es);
            t.start();
        }
    }
    public void run()
    {
        try {       
            BufferedReader in = new BufferedReader(new
InputStreamReader(socket.getInputStream()));
            while(true)
            {
                System.out.println(in.readLine());
            }
        }
        catch(Exception e)
        {}
    }
}

Output: