线程同步类，定义AtomicInteger原子变量，实现线程同步

1. import java.util.concurrent.atomic.AtomicInteger;
   
2. 
   
3. public class AtomicIntegerDemo implements Runnable {
   
4.    
   
5.     private AtomicInteger number = new AtomicInteger(0);// 创建一个AtomicInteger类型变量进行测试
   
6.    
   
7.     @Override
   
8.     public void run() {
   
9.         for (int i = 0; i < 5; i++) {
   
10.             try {
    
11.                 Thread.sleep(100);// 线程休眠0.1秒增加出错几率
    
12.             } catch (InterruptedException e) {
    
13.                 e.printStackTrace();
    
14.             }
    
15.             // 输出当前线程的名称和number的值，每次循环之后number的值都会加一
    
16.             System.out.println(Thread.currentThread().getName() + ": "
    
17.                     + number.getAndIncrement());
    
18.         }
    
19.     }
    
20.    
    
21.     public static void main(String[] args) {
    
22.         AtomicIntegerDemo run = new AtomicIntegerDemo();// 获得AtomicIntegerDemo对象
    
23.         Thread thread1 = new Thread(run);// 创建线程1
    
24.         Thread thread2 = new Thread(run);// 创建线程2
    
25.         thread1.start();// 运行线程1
    
26.         thread2.start();// 运行线程2
    
27.     }
    
28. }

复制代码

运行结果：
Thread-0: 0
Thread-1: 1
Thread-0: 2
Thread-1: 3
Thread-1: 4
Thread-0: 5
Thread-1: 6
Thread-0: 7
Thread-1: 8
Thread-0: 9

线程同步类，定义AtomicInteger原子变量，实现线程同步

1. import java.util.concurrent.atomic.AtomicInteger;
   
2. 
   
3. public class AtomicIntegerDemo implements Runnable {
   
4.    
   
5.     private AtomicInteger number = new AtomicInteger(0);// 创建一个AtomicInteger类型变量进行测试
   
6.    
   
7.     @Override
   
8.     public void run() {
   
9.         for (int i = 0; i < 5; i++) {
   
10.             try {
    
11.                 Thread.sleep(100);// 线程休眠0.1秒增加出错几率
    
12.             } catch (InterruptedException e) {
    
13.                 e.printStackTrace();
    
14.             }
    
15.             // 输出当前线程的名称和number的值，每次循环之后number的值都会加一
    
16.             System.out.println(Thread.currentThread().getName() + ": "
    
17.                     + number.getAndIncrement());
    
18.         }
    
19.     }
    
20.    
    
21.     public static void main(String[] args) {
    
22.         AtomicIntegerDemo run = new AtomicIntegerDemo();// 获得AtomicIntegerDemo对象
    
23.         Thread thread1 = new Thread(run);// 创建线程1
    
24.         Thread thread2 = new Thread(run);// 创建线程2
    
25.         thread1.start();// 运行线程1
    
26.         thread2.start();// 运行线程2
    
27.     }
    
28. }

复制代码

运行结果：
Thread-0: 0
Thread-1: 1
Thread-0: 2
Thread-1: 3
Thread-1: 4
Thread-0: 5
Thread-1: 6
Thread-0: 7
Thread-1: 8
Thread-0: 9