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("多线程测试结束。。。。。。。。");
    }

  • 相关阅读:
    安装AD域时,出现NetBIOS名称冲突?
    SharePoint Server 2010 安装图解
    Visual C++ 2011519
    Visual C++ 2011520
    Visual C++ 2011518
    Visual C++ 2011520
    设计模式创建型 C++版本
    线程条件变量,一次性初始化
    Visual C++ 2011526
    Visual C++ 2011512
  • 原文地址:https://www.cnblogs.com/lhl-shubiao/p/8494593.html
Copyright © 2011-2022 走看看