zoukankan      html  css  js  c++  java
  • 多线程并发的问题解决方案

    多线程并发的问题解决方案

    package map;

    import java.util.HashMap;
    import java.util.Hashtable;
    import java.util.Map;

    public class TestConCurrentMap {
    static int index;
    public static void main(String[] args) {
    execute();
    }

    public static synchronized void execute(){
    final Map<Integer, Integer> map = new HashMap<Integer, Integer>();
    for (int i = 0; i < 10; i++) {
    new Thread(new Runnable() {
    public void run() {
    map.put(index++, index);
    while(true){
    System.out.println(Thread.currentThread().getName()+":"+map);
    try {
    Thread.sleep(1000);
    } catch (Exception e) {
    e.printStackTrace();
    }
    }
    }
    }).start();
    }
    }
    }

    ----------------------------------------------------------------------------------------------------------
    // @Test
    public void testIsClose4WBDMultiThread(){
    System.out.println("多线程测试开始。。。。。。。。");
    Runnable task = new Runnable() {

    @Override
    public void run() {
    try {
    System.out.println("进入task任务");
    TradingHourServiceProvider provider = TradingHourServiceProvider.get();
    boolean b = provider.isClose4WBD(DateUtil.toDate("2017-09-06", DateUtil.PATTERN_DATE2));
    System.out.println(b);
    // Map<CacheType, String> cache = ConfigCache.get().getCache();
    } catch (GenericTsException e) {
    e.printStackTrace();
    }
    }
    };
    Map<Thread, String> map = new HashMap<Thread,String>();
    for(int i =0;i<20;i++){
    Thread t = new Thread(task);
    t.currentThread().setName("线程"+i);
    map.put(t, t.getName());
    }

    Set<Thread> threadSet = map.keySet();
    for (Thread t : threadSet) {
    t.start();
    }

    try {
    Thread.sleep(5000);
    } catch (InterruptedException e) {
    e.printStackTrace();
    }

    System.out.println("多线程测试结束。。。。。。。。");
    }

    @Test
    public void testHashMapMultiThread(){
    System.out.println("多线程测试开始。。。。。。。。");
    Runnable task = new Runnable() {

    @Override
    public void run() {
    try {
    System.out.println("进入task任务");
    TradingHourServiceProvider provider = TradingHourServiceProvider.get();
    boolean b = provider.isClose4WBD(DateUtil.toDate("2017-09-06", DateUtil.PATTERN_DATE2));
    System.out.println(b);
    // Map<CacheType, String> cache = ConfigCache.get().getCache();
    } catch (GenericTsException e) {
    e.printStackTrace();
    }
    }
    };
    Map<Thread, String> map = new HashMap<Thread,String>();
    for(int i =0;i<8;i++){
    Thread t = new Thread(task);
    t.currentThread().setName("线程"+i);
    map.put(t, t.getName());
    }

    Set<Thread> threadSet = map.keySet();
    for (Thread t : threadSet) {
    t.start();
    }

    try {
    Thread.sleep(5000);
    } catch (InterruptedException e) {
    e.printStackTrace();
    }

    System.out.println("多线程测试结束。。。。。。。。");
    }

  • 相关阅读:
    [ Luogu 3398 ] 仓鼠找sugar
    [ JLOI 2014 ] 松鼠的新家
    AtcoderGrandContest 005 F. Many Easy Problems
    Codeforces 388 D. Fox and Perfect Sets
    Codeforces 1037 H. Security
    「学习笔记」wqs二分/dp凸优化
    「NOI2017」游戏
    「SCOI2014」方伯伯的商场之旅
    「SCOI2015」情报传递
    「SCOI2016」美味
  • 原文地址:https://www.cnblogs.com/lhl-shubiao/p/8494593.html
Copyright © 2011-2022 走看看