j_synchronization.java

来自「一个十分好的java基础学习的课件」· Java 代码 · 共 90 行

// ////////////////////////////////////////////////////////
// 
// J_Synchronization.java
// 

// ////////////////////////////////////////////////////////

class J_Experiment
{
    private int m_temperature, m_pressure;
    
    public void mb_update(int t, int p)
    {
        m_temperature = t;
        m_pressure    = p;
    } // End of method: mb_update
    
    public void mb_analyze( )
    {
        int t= m_temperature;
        int p= m_pressure;
        if (t!=m_temperature)
        {
            System.out.print("It is very dangerous now: ");
            System.out.println("t(" + t + ") != (" + m_temperature + ")");
            System.exit(0);
        }
        if (p!= m_pressure)
        {
            System.out.print("It is very dangerous now: ");
            System.out.println("p(" + p + ") != (" + m_pressure + ")");
            System.exit(0);
        }
    } // End of method: mb_analyze
} // End of class: J_Experiment

class J_Assistant extends Thread
{
    J_Experiment m_data;
    
    public J_Assistant(J_Experiment d)
    {
        m_data= d;
    } // End of constructor

    public void run( )
    {
        int i, j;
        for(; true; )
        {
            i= (int)(Math.random( ) * 1000);
            j= (int)(Math.random( ) * 1000);
            m_data.mb_update(i, j);
        }
    } // End of method: run
} // End of class: J_Assistant

class J_Analyst extends Thread
{
    J_Experiment m_data;
    
    public J_Analyst(J_Experiment d)
    {
        m_data= d;
    } // End of constructor
    
    public void run( )
    {
        int i;
        for(; true; )
        {
            m_data.mb_analyze( );
        }
    } // End of method: run
} // End of class: J_Analyst

public class J_Synchronization
{
    
    public static void main( String args[] )
    { 
        J_Experiment data= new J_Experiment( );
        J_Assistant threadA = new J_Assistant(data);
        J_Analyst   threadB = new J_Analyst(data);
        threadA.start( );
        threadB.start( );
    } // End of method: main

}  // End of class: J_Synchronization