Java: CAS

妖狐艹你老母 2023-07-15 09:01 4阅读 0赞

package cas;
    
    import java.lang.reflect.Field;
    import java.security.AccessController;
    import java.security.PrivilegedExceptionAction;
    
    import sun.misc.Unsafe;
    
    public class Person {
    	private int i=0;
    	private static Unsafe UNSAFE=null;
    	private static long I_OFFSET;
    	static
    	{
    		
    		try {
    			Field f = Unsafe.class.getDeclaredField("theUnsafe");
    		
    		f.setAccessible(true);
    		UNSAFE = (Unsafe) f.get(null);
    		I_OFFSET=UNSAFE.objectFieldOffset(Person.class.getDeclaredField("i"));
    		
    		
    		}
    		catch(Exception ex)
    		{
    			System.out.println(ex.getMessage());
    		}
    	}
    	
    
    	private static Person person=new Person();
    	public static void main(String[] args) throws InterruptedException {
    		
    		
    		new Thread(new Runnable() {
    
    			@Override
    			public void run() {
    				while(true)
    				{
    					//person.i++;
    					//System.out.println(person.i);
    					
    					
    					boolean b=UNSAFE.compareAndSwapInt(person, I_OFFSET, person.i, person.i+1);
    					if(b)
    					{
    						System.out.println("01: "+UNSAFE.getIntVolatile(person,I_OFFSET));
    					}
    					
    					else System.out.println("Cas 01 failed.I will try again!");
    				try {
    					Thread.sleep(600);
    				} catch (InterruptedException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    				
    				
    				}
    				
    			}
    			
    		}).start();
    		
    		
    		new Thread(new Runnable() {
    
    			@Override
    			public void run() {
    				while(true)
    				{
    					//person.i++;
    					//System.out.println(person.i);
    					
    					
    					boolean b=UNSAFE.compareAndSwapInt(person, I_OFFSET, person.i, person.i+1);
    					if(b)
    					{
    						System.out.println("02: "+UNSAFE.getIntVolatile(person,I_OFFSET));
    					}
    					
    					else System.out.println("Cas 02 failed.I will try again!");
    				try {
    					Thread.sleep(600);
    				} catch (InterruptedException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    				
    				
    				}
    				
    			}
    			
    		}).start();
    		
    		
    		new Thread(new Runnable() {
    
    			@Override
    			public void run() {
    				while(true)
    				{
    					//person.i++;
    					//System.out.println(person.i);
    					
    					
    					boolean b=UNSAFE.compareAndSwapInt(person, I_OFFSET, person.i, person.i+1);
    					if(b)
    					{
    						System.out.println("03: "+UNSAFE.getIntVolatile(person,I_OFFSET));
    					}
    					
    					else System.out.println("Cas 03 failed.I will try again!");
    				try {
    					Thread.sleep(600);
    				} catch (InterruptedException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    				
    				
    				}
    				
    			}
    			
    		}).start();
    		
    	
    	
    	
    
    }
    }