Scala parallel collections, parallel concurrency, thread safety issues, ThreadLocal

---

1. scala并行集合

  ScalaProvide parallel collection,用于多核环境的并行计算,充分使用多核CPU

object T34 {
    
  def main(args: Array[String]): Unit = {
    
    val result = (0 to 20).par.map {
     x => Thread.currentThread.getName }
    println(result)
  }
}

并行：Two or more events occur at the same time（多核CPU）
并发：两个或多个事件在同一时间段内发生（Multithreaded competition resources）

---

2. 线程安全问题

   Multi-threaded concurrent modification,To modify a Shared object attribute in the Shared memory所导致的数据冲突问题

public class T45 {
    
    public static void main(String[] args) {
    
        User user = new User();
        Thread thread1 = new Thread(new Runnable() {
    
            @Override
            public void run() {
    
                user.name = "zs";
                try {
    
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
    
                    e.printStackTrace();
                }
                System.out.println(user.name);
            }
        });
        Thread thread2 = new Thread(new Runnable() {
    
            @Override
            public void run() {
    
                user.name = "lisi";
                try {
    
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
    
                    e.printStackTrace();
                }
                System.out.println(user.name);
            }
        });
        thread1.start();
        thread2.start();
        System.out.println("main");
    }
}

class User {
    
     public String name;

}

---

3. ThreadLocal

   ThreadLocal中填充的变量属于当前线程,For other threads is to isolate the.ThreadLocal为变量在每个线程中都创建了一个副本,Copies of each thread access to their internal variables.因此不存在线程安全问题

public class T45 {
    
    public static void main(String[] args) {
    
        User user = new User();
        //线程安全问题： Multi-threaded concurrent modification,Shared in the Shared memory object properties caused by modified data conflict
        Thread thread1 = new Thread(new Runnable() {
    
            @Override
            public void run() {
    
                user.name.set("zs");
                try {
    
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
    
                    e.printStackTrace();
                }
                System.out.println(user.name.get());
            }
        });
        Thread thread2 = new Thread(new Runnable() {
    
            @Override
            public void run() {
    
                user.name.set("lisi");
                try {
    
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
    
                    e.printStackTrace();
                }
                System.out.println(user.name.get());
            }
        });
        thread1.start();
        thread2.start();
        System.out.println("main");
    }
}

class User {
    
    public ThreadLocal<String> name=new ThreadLocal<>();
}