多线程并发测试代码及解决方法详解编程语言

1.解决方法

Executors.newSingleThreadExecutor()取得的Executor实例有以下特性:

任务顺序执行. 比如：

executor.submit(task1);

executor.submit(task2);

必须等task1执行完，task2才能执行。

task1和task2会被放入一个队列里，由一个工作线程来处理。即：一共有2个线程(主线程、处理任务的工作线程）。

以上如果是单机可以解决,如果是多台服务器的话,仍然还是会存在并发的问题.

或者使用mysql数据库修改的特性,update排序依次来修改,增加否决字段,修改的时候带上条件值,可以解决并发问题.(多个租客租时间段重叠的同一辆车且自动接单,这个情况就很明显凸现出来.)

2.测试代码

/** 
 *  
 */ 
package mock; 
 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 
import java.util.concurrent.Semaphore; 
 
import com.autoyolConsole.util.esb.HttpUtils; 
 
/** 
 * @author xxx 
 * @function  
 * @date 2016年3月15日 
 * @version 1.0 
 */ 
public class ConcurrentTest2 { 
    private static int thread_num = 5; 
    private static int client_num = 20; 
    private static final String reqUrl = "http://10.0.3.213:7064/"; 
    private static String url = "tranxx/vxx/reqx"; 
     
    private static String[] tokens = new String[]{"4dafe25e1f8f4e368834f95b75030193","6a3d3702cccf46a3b94e2c805a16c0a3","a4ee5ad888714a9e9d0d4646e725495b","9adbecae26f648dea2767e8d908463dd","20910b477f0142f6b7f709babcdafb72", 
        "c3c53c987256422a8667a455a1cd1117","efb1f941eab440619d8a339f2fafa429","786a901fe5414d14894ca4db738efe2f","8fbad92b9a7c4d4b8a420db23c405e49","75992aa62eb947739f0bfc8a83234584", 
        "aa110a58ade241a3b456b8be5ddd2551","aa110a58ade241a3b456b8be5ddd255a","aa110a58ade241a3b456b8be5ddd2552","aa110a58ade241a3b456b8be5ddd2553","aa110a58ade241a3b456b8be5ddd2554", 
        "aa110a58ade241a3b456b8be5ddd2555","aa110a58ade241a3b456b8be5ddd2556","aa110a58ade241a3b456b8be5ddd2557","aa110a58ade241a3b456b8be5ddd2558","aa110a58ade241a3b456b8be5ddd2559"}; 
     
    private static String[] mobiles = new String[]{"197xxxx9705","199xxxx5297","199xxxx8606","198xxxx9898","197xxxx1330", 
        "197xxxx9999","193xxxx2233","193xxxx2345","191xxxx6712","198xxxx6852", 
        "191xxxx6820","987xxxx0296","190xxxx7589","199xxxx8888","193xxxx2312", 
        "199xxxx5496","161xxxx3280","190xxxx1082","199xxxx3724","199xxxx0537"}; 
     
    public static void main(String[] args) { 
        ExecutorService exec = Executors.newCachedThreadPool(); 
        // thread_num个线程可以同时访问 
        final Semaphore semp = new Semaphore(thread_num); 
        // 模拟client_num个客户端访问 
        for (int index = 0; index < client_num; index++) { 
            final int NO = index; 
            Runnable run = new Runnable() { 
                public void run() { 
                    try { 
                        // 获取许可 
                        semp.acquire(); 
                         
                        System.out.println("Thread并发事情>>>"+ NO); 
                         
                        String strReq = "{/"carNo/":/"303473636/",/"token/":/""+tokens[NO]+"/",/"conPhone/":/""+mobiles[NO]+"/"," 
                                + "/"rentTime/":/"20160519183000/",/"revertTime/":/"20160522183000/",/"rentReason/":/"上下班用车/",/"oilType/":/"1/",/"disCouponIds/":/"0/",/"useBal/":/"0/",/"source/":/"3/",/"rentCity/":/"本市/"}"; 
                         
                        try { 
                            String result = HttpUtils.appPost(strReq, reqUrl+ url); 
                            System.err.println("接口调用返回结果：" + result); 
                        } catch (Exception e) { 
                            e.printStackTrace(); 
                        } 
                         
                        semp.release(); 
                    } catch (Exception e) { 
                        e.printStackTrace(); 
                    } 
                } 
            }; 
            exec.execute(run); 
        } 
        // 退出线程池 
        exec.shutdown(); 
    } 
}

原创文章，作者：Maggie-Hunter，如若转载，请注明出处：https://blog.ytso.com/15255.html

多线程并发测试代码及解决方法详解编程语言

相关推荐

发表回复