package concurrent.runnable;

/**
 * Created by Edwin Xu on 8/27/2020 1:36 PM
 */
public class MyTask implements Runnable {
    private Integer cnt = 0;
    @Override
    public void run() {
        while (true) {
            synchronized (cnt) {
                System.out.println("cnt = " + cnt++ + " by " + Thread.currentThread().getName());
            }
            try {
                Thread.sleep(1000);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
    public static void main(String[] args) {
        MyTask t1 = new MyTask(); //这是一个任务：1
        MyTask t2 = new MyTask(); //这是另一个任务：2

        Thread thread1 = new Thread(t1);
        Thread thread2 = new Thread(t1); // 线程2如果也和任务1绑定，那么两个线程共享任务1的变量，
                                         // 否则两个线程执行不同的任务，互不影响
        thread1.start();
        thread2.start();
    }
}