日韩成人免费在线_国产成人一二_精品国产免费人成电影在线观..._日本一区二区三区久久久久久久久不

當前位置:首頁 > 科技  > 軟件

獲取雙異步返回值時,如何保證主線程不阻塞?

來源: 責編: 時間:2024-01-25 10:41:34 246觀看
導(dǎo)讀一、前情提要在上一篇文章中,使用雙異步后,如何保證數(shù)據(jù)一致性?,通過Future獲取異步返回值,輪詢判斷Future狀態(tài),如果執(zhí)行完畢或已取消,則通過get()獲取返回值,get()是阻塞的方法,因此會阻塞當前線程,如果通過new Runnable()執(zhí)行

nkJ28資訊網(wǎng)——每日最新資訊28at.com

一、前情提要

在上一篇文章中,使用雙異步后,如何保證數(shù)據(jù)一致性?,通過Future獲取異步返回值,輪詢判斷Future狀態(tài),如果執(zhí)行完畢或已取消,則通過get()獲取返回值,get()是阻塞的方法,因此會阻塞當前線程,如果通過new Runnable()執(zhí)行g(shù)et()方法,那么還是需要返回AsyncResult,然后再通過主線程去get()獲取異步線程返回結(jié)果。nkJ28資訊網(wǎng)——每日最新資訊28at.com

寫法很繁瑣,還會阻塞主線程。nkJ28資訊網(wǎng)——每日最新資訊28at.com

下面是FutureTask異步執(zhí)行流程圖:nkJ28資訊網(wǎng)——每日最新資訊28at.com

nkJ28資訊網(wǎng)——每日最新資訊28at.com

二、JDK8的CompletableFuture

1、ForkJoinPool

Java8中引入了CompletableFuture,它實現(xiàn)了對Future的全面升級,可以通過回調(diào)的方式,獲取異步線程返回值。nkJ28資訊網(wǎng)——每日最新資訊28at.com

CompletableFuture的異步執(zhí)行通過ForkJoinPool實現(xiàn), 它使用守護線程去執(zhí)行任務(wù)。nkJ28資訊網(wǎng)——每日最新資訊28at.com

ForkJoinPool在于可以充分利用多核CPU的優(yōu)勢,把一個任務(wù)拆分成多個小任務(wù),把多個小任務(wù)放到多個CPU上并行執(zhí)行,當多個小任務(wù)執(zhí)行完畢后,再將其執(zhí)行結(jié)果合并起來。nkJ28資訊網(wǎng)——每日最新資訊28at.com

Future的異步執(zhí)行是通過ThreadPoolExecutor實現(xiàn)的。nkJ28資訊網(wǎng)——每日最新資訊28at.com

nkJ28資訊網(wǎng)——每日最新資訊28at.com

2、從ForkJoinPool和ThreadPoolExecutor探索CompletableFuture和Future的區(qū)別

  • ForkJoinPool中的每個線程都會有一個隊列,而ThreadPoolExecutor只有一個隊列,并根據(jù)queue類型不同,細分出各種線程池;
  • ForkJoinPool在使用過程中,會創(chuàng)建大量的子任務(wù),會進行大量的gc,但是ThreadPoolExecutor不需要,因為ThreadPoolExecutor是任務(wù)分配平均的;
  • ThreadPoolExecutor中每個異步線程之間是相互獨立的,當執(zhí)行速度快的線程執(zhí)行完畢后,它就會一直處于空閑的狀態(tài),等待其它線程執(zhí)行完畢;
  • ForkJoinPool中每個異步線程之間并不是絕對獨立的,在ForkJoinPool線程池中會維護一個隊列來存放需要執(zhí)行的任務(wù),當線程自身任務(wù)執(zhí)行完畢后,它會從其它線程中獲取未執(zhí)行的任務(wù)并幫助它執(zhí)行,直至所有線程執(zhí)行完畢。

因此,在多線程任務(wù)分配不均時,F(xiàn)orkJoinPool的執(zhí)行效率更高。但是,如果任務(wù)分配均勻,ThreadPoolExecutor的執(zhí)行效率更高,因為ForkJoinPool會創(chuàng)建大量子任務(wù),并對其進行大量的GC,比較耗時。nkJ28資訊網(wǎng)——每日最新資訊28at.com

三、通過CompletableFuture優(yōu)化 “通過Future獲取異步返回值”

1、通過Future獲取異步返回值關(guān)鍵代碼

(1)將異步方法的返回值改為Future<Integer>,將返回值放到new AsyncResult<>();中

@Async("async-executor")public void readXls(String filePath, String filename) {    try {     // 此代碼為簡化關(guān)鍵性代碼        List<Future<Integer>> futureList = new ArrayList<>();        for (int time = 0; time < times; time++) {            Future<Integer> sumFuture = readExcelDataAsyncFutureService.readXlsCacheAsync();            futureList.add(sumFuture);        }    }catch (Exception e){        logger.error("readXlsCacheAsync---插入數(shù)據(jù)異常:",e);    }}
@Async("async-executor")public Future<Integer> readXlsCacheAsync() {    try {        // 此代碼為簡化關(guān)鍵性代碼        return new AsyncResult<>(sum);    }catch (Exception e){        return new AsyncResult<>(0);    }}

(2)通過Future<Integer>.get()獲取返回值

public static boolean getFutureResult(List<Future<Integer>> futureList, int excelRow) {    int[] futureSumArr = new int[futureList.size()];    for (int i = 0;i<futureList.size();i++) {        try {            Future<Integer> future = futureList.get(i);            while (true) {                if (future.isDone() && !future.isCancelled()) {                    Integer futureSum = future.get();                    logger.info("獲取Future返回值成功"+"----Future:" + future                            + ",Result:" + futureSum);                    futureSumArr[i] += futureSum;                    break;                } else {                    logger.info("Future正在執(zhí)行---獲取Future返回值中---等待3秒");                    Thread.sleep(3000);                }            }        } catch (Exception e) {            logger.error("獲取Future返回值異常: ", e);        }    }        boolean insertFlag = getInsertSum(futureSumArr, excelRow);    logger.info("獲取所有異步線程Future的返回值成功,Excel插入結(jié)果="+insertFlag);    return insertFlag;}

2、通過CompletableFuture獲取異步返回值關(guān)鍵代碼

(1)將異步方法的返回值改為 int

@Async("async-executor")public void readXls(String filePath, String filename) { List<CompletableFuture<Integer>> completableFutureList = new ArrayList<>();    for (int time = 0; time < times; time++) {     // 此代碼為簡化關(guān)鍵性代碼        CompletableFuture<Integer> completableFuture = CompletableFuture.supplyAsync(new Supplier<Integer>() {         @Override         public Integer get() {             return readExcelDbJdk8Service.readXlsCacheAsyncMybatis();         }     }).thenApply((result) -> {// 回調(diào)方法         return thenApplyTest2(result);// supplyAsync返回值 * 1     }).thenApply((result) -> {         return thenApplyTest5(result);// thenApply返回值 * 1     }).exceptionally((e) -> { // 如果執(zhí)行異常:         logger.error("CompletableFuture.supplyAsync----異常:", e);         return null;     });      completableFutureList.add(completableFuture);    }}
@Async("async-executor")public int readXlsCacheAsync() {    try {        // 此代碼為簡化關(guān)鍵性代碼        return sum;    }catch (Exception e){        return -1;    }}

(2)通過completableFuture.get()獲取返回值

public static boolean getCompletableFutureResult(List<CompletableFuture<Integer>> list, int excelRow){    logger.info("通過completableFuture.get()獲取每個異步線程的插入結(jié)果----開始");    int sum = 0;    for (int i = 0; i < list.size(); i++) {        Integer result = list.get(i).get();        sum += result;    }    boolean insertFlag = excelRow == sum;    logger.info("全部執(zhí)行完畢,excelRow={},入庫={}, 數(shù)據(jù)是否一致={}",excelRow,sum,insertFlag);    return insertFlag;}

3、效率對比

(1)測試環(huán)境

  • 12個邏輯處理器的電腦;
  • Excel中包含10萬條數(shù)據(jù);
  • Future的自定義線程池,核心線程數(shù)為24;
  • ForkJoinPool的核心線程數(shù)為24;

(2)統(tǒng)計四種情況下10萬數(shù)據(jù)入庫時間

  • 不獲取異步返回值
  • 通過Future獲取異步返回值
  • 通過CompletableFuture獲取異步返回值,默認ForkJoinPool線程池的核心線程數(shù)為本機邏輯處理器數(shù)量,測試電腦為12;
  • 通過CompletableFuture獲取異步返回值,修改ForkJoinPool線程池的核心線程數(shù)為24。

備注:因為CompletableFuture不阻塞主線程,主線程執(zhí)行時間只有2秒,表格中統(tǒng)計的是異步線程全部執(zhí)行完成的時間。nkJ28資訊網(wǎng)——每日最新資訊28at.com

(3)設(shè)置核心線程數(shù)

將核心線程數(shù)CorePoolSize設(shè)置成CPU的處理器數(shù)量,是不是效率最高的?nkJ28資訊網(wǎng)——每日最新資訊28at.com

// 獲取CPU的處理器數(shù)量int curSystemThreads = Runtime.getRuntime().availableProcessors() * 2;// 測試電腦是24

因為在接口被調(diào)用后,開啟異步線程,執(zhí)行入庫任務(wù),因為測試機最多同時開啟24線程處理任務(wù),故將10萬條數(shù)據(jù)拆分成等量的24份,也就是10萬/24 = 4166,那么我設(shè)置成4200,是不是效率最佳呢?nkJ28資訊網(wǎng)——每日最新資訊28at.com

測試的過程中發(fā)現(xiàn),好像真的是這樣的。nkJ28資訊網(wǎng)——每日最新資訊28at.com

自定義ForkJoinPool線程池
@Autowired@Qualifier("asyncTaskExecutor")private Executor asyncTaskExecutor;@Overridepublic void readXls(String filePath, String filename) {  List<CompletableFuture<Integer>> completableFutureList = new ArrayList<>();    for (int time = 0; time < times; time++) {  CompletableFuture<Integer> completableFuture = CompletableFuture.supplyAsync(new Supplier<Integer>() {         @Override         public Integer get() {             try {                 return readExcelDbJdk8Service.readXlsCacheAsync(sheet, row, start, finalEnd, insertBuilder);             } catch (Exception e) {                 logger.error("CompletableFuture----readXlsCacheAsync---異常:", e);                 return -1;             }         };     },asyncTaskExecutor);      completableFutureList.add(completableFuture); } // 不會阻塞主線程    CompletableFuture.allOf(completableFutureList.toArray(new CompletableFuture[completableFutureList.size()])).whenComplete((r,e) -> {        try {            int insertSum = getCompletableFutureResult(completableFutureList, excelRow);        } catch (Exception ex) {            return;        }    });}
自定義線程池
/** * 自定義異步線程池 */@Bean("asyncTaskExecutor")public AsyncTaskExecutor asyncTaskExecutor() {    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();    //設(shè)置線程名稱    executor.setThreadNamePrefix("asyncTask-Executor");    //設(shè)置最大線程數(shù)    executor.setMaxPoolSize(200);    //設(shè)置核心線程數(shù)    executor.setCorePoolSize(24);    //設(shè)置線程空閑時間,默認60    executor.setKeepAliveSeconds(200);    //設(shè)置隊列容量    executor.setQueueCapacity(50);    /**     * 當線程池的任務(wù)緩存隊列已滿并且線程池中的線程數(shù)目達到maximumPoolSize,如果還有任務(wù)到來就會采取任務(wù)拒絕策略     * 通常有以下四種策略:     * ThreadPoolExecutor.AbortPolicy:丟棄任務(wù)并拋出RejectedExecutionException異常。     * ThreadPoolExecutor.DiscardPolicy:也是丟棄任務(wù),但是不拋出異常。     * ThreadPoolExecutor.DiscardOldestPolicy:丟棄隊列最前面的任務(wù),然后重新嘗試執(zhí)行任務(wù)(重復(fù)此過程)     * ThreadPoolExecutor.CallerRunsPolicy:重試添加當前的任務(wù),自動重復(fù)調(diào)用 execute() 方法,直到成功     */    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());    executor.initialize();    return executor;}

nkJ28資訊網(wǎng)——每日最新資訊28at.com

(4)統(tǒng)計分析

效率對比:nkJ28資訊網(wǎng)——每日最新資訊28at.com

③通過CompletableFuture獲取異步返回值(12線程) <  ②通過Future獲取異步返回值 <  ④通過CompletableFuture獲取異步返回值(24線程) <  ①不獲取異步返回值nkJ28資訊網(wǎng)——每日最新資訊28at.com

不獲取異步返回值時性能最優(yōu),這不廢話嘛~nkJ28資訊網(wǎng)——每日最新資訊28at.com

核心線程數(shù)相同的情況下,CompletableFuture的入庫效率要優(yōu)于Future的入庫效率,10萬條數(shù)據(jù)大概要快4秒鐘,這還是相當驚人的,優(yōu)化的價值就在于此。nkJ28資訊網(wǎng)——每日最新資訊28at.com

nkJ28資訊網(wǎng)——每日最新資訊28at.com

四、通過CompletableFuture.allOf解決阻塞主線程問題

1、語法

CompletableFuture.allOf(CompletableFuture的可變數(shù)組).whenComplete((r,e) -> {})。nkJ28資訊網(wǎng)——每日最新資訊28at.com

2、代碼實例

getCompletableFutureResult方法在 “3.2.2 通過completableFuture.get()獲取返回值”。nkJ28資訊網(wǎng)——每日最新資訊28at.com

// 不會阻塞主線程CompletableFuture.allOf(completableFutureList.toArray(new   CompletableFuture[completableFutureList.size()])).whenComplete((r,e) -> {    logger.info("全部執(zhí)行完畢,解決主線程阻塞問題~");    try {        int insertSum = getCompletableFutureResult(completableFutureList, excelRow);    } catch (Exception ex) {        logger.error("全部執(zhí)行完畢,解決主線程阻塞問題,異常:", ex);        return;    }});// 會阻塞主線程//getCompletableFutureResult(completableFutureList, excelRow);logger.info("CompletableFuture----會阻塞主線程嗎?");

nkJ28資訊網(wǎng)——每日最新資訊28at.com

五、CompletableFuture中花俏的語法糖

1、runAsync

runAsync 方法不支持返回值。nkJ28資訊網(wǎng)——每日最新資訊28at.com

可以通過runAsync執(zhí)行沒有返回值的異步方法。nkJ28資訊網(wǎng)——每日最新資訊28at.com

不會阻塞主線程。nkJ28資訊網(wǎng)——每日最新資訊28at.com

// 分批異步讀取Excel內(nèi)容并入庫int finalEnd = end;CompletableFuture.runAsync(() -> readExcelDbJdk8Service.readXlsCacheAsyncMybatis();

2、supplyAsync

supplyAsync也可以異步處理任務(wù),傳入的對象實現(xiàn)了Supplier接口。將Supplier作為參數(shù)并返回CompletableFuture結(jié)果值,這意味著它不接受任何輸入?yún)?shù),而是將result作為輸出返回。nkJ28資訊網(wǎng)——每日最新資訊28at.com

會阻塞主線程。nkJ28資訊網(wǎng)——每日最新資訊28at.com

supplyAsync()方法關(guān)鍵代碼:nkJ28資訊網(wǎng)——每日最新資訊28at.com

int finalEnd = end;CompletableFuture<Integer> completableFuture = CompletableFuture.supplyAsync(new Supplier<Integer>() {    @Override    public Integer get() {        return readExcelDbJdk8Service.readXlsCacheAsyncMybatis();    }});
@Overridepublic int readXlsCacheAsyncMybatis() {    // 不為人知的操作    // 返回異步方法執(zhí)行結(jié)果即可 return 100;}

六、順序執(zhí)行異步任務(wù)

1、thenRun

thenRun()不接受參數(shù),也沒有返回值,與runAsync()配套使用,恰到好處。nkJ28資訊網(wǎng)——每日最新資訊28at.com

// JDK8的CompletableFutureCompletableFuture.runAsync(() -> readExcelDbJdk8Service.readXlsCacheAsyncMybatis()).thenRun(() -> logger.info("CompletableFuture----.thenRun()方法測試"));

nkJ28資訊網(wǎng)——每日最新資訊28at.com

2、thenAccept

thenAccept()接受參數(shù),沒有返回值。nkJ28資訊網(wǎng)——每日最新資訊28at.com

supplyAsync + thenAcceptnkJ28資訊網(wǎng)——每日最新資訊28at.com

  • 異步線程順序執(zhí)行
  • supplyAsync的異步返回值,可以作為thenAccept的參數(shù)使用
  • 不會阻塞主線程
CompletableFuture.supplyAsync(new Supplier<Integer>() {    @Override    public Integer get() {        return readExcelDbJdk8Service.readXlsCacheAsyncMybatis();    }}).thenAccept(x -> logger.info(".thenAccept()方法測試:" + x));

nkJ28資訊網(wǎng)——每日最新資訊28at.com

但是,此時無法通過completableFuture.get()獲取supplyAsync的返回值了。nkJ28資訊網(wǎng)——每日最新資訊28at.com

3、thenApply

thenApply在thenAccept的基礎(chǔ)上,可以再次通過completableFuture.get()獲取返回值。nkJ28資訊網(wǎng)——每日最新資訊28at.com

supplyAsync + thenApply,典型的鏈式編程。nkJ28資訊網(wǎng)——每日最新資訊28at.com

  • 異步線程內(nèi)方法順序執(zhí)行。
  • supplyAsync 的返回值,作為第 1 個thenApply的參數(shù),進行業(yè)務(wù)處理。
  • 第 1 個thenApply的返回值,作為第 2 個thenApply的參數(shù),進行業(yè)務(wù)處理。
  • 最后,通過future.get()方法獲取最終的返回值。
CompletableFuture<Integer> completableFuture = CompletableFuture.supplyAsync(new Supplier<Integer>() { @Override    public Integer get() {        return readExcelDbJdk8Service.readXlsCacheAsyncMybatis();    }}).thenApply((result) -> {    return thenApplyTest2(result);// supplyAsync返回值 * 2}).thenApply((result) -> {    return thenApplyTest5(result);// thenApply返回值 * 5});logger.info("readXlsCacheAsyncMybatis插入數(shù)據(jù) * 2 * 5 = " + completableFuture.get());

nkJ28資訊網(wǎng)——每日最新資訊28at.com

七、CompletableFuture合并任務(wù)

  • thenCombine,多個異步任務(wù)并行處理,有返回值,最后合并結(jié)果返回新的CompletableFuture對象。
  • thenAcceptBoth,多個異步任務(wù)并行處理,無返回值。
  • acceptEither,多個異步任務(wù)并行處理,無返回值。
  • applyToEither,,多個異步任務(wù)并行處理,有返回值。

CompletableFuture合并任務(wù)的代碼實例,這里就不多贅述了,一些語法糖而已,大家切記陷入低水平勤奮的怪圈。nkJ28資訊網(wǎng)——每日最新資訊28at.com

八、CompletableFuture VS Future總結(jié)

本文中以下幾個方面對比了CompletableFuture和Future的差異:nkJ28資訊網(wǎng)——每日最新資訊28at.com

  • ForkJoinPool和ThreadPoolExecutor的實現(xiàn)原理,探索了CompletableFuture和Future的差異。
  • 通過代碼實例的形式簡單介紹了CompletableFuture中花俏的語法糖。
  • 通過CompletableFuture優(yōu)化了 “通過Future獲取異步返回值”。
  • 通過CompletableFuture.allOf解決阻塞主線程問題。

Future提供了異步執(zhí)行的能力,但Future.get()會通過輪詢的方式獲取異步返回值,get()方法還會阻塞主線程。nkJ28資訊網(wǎng)——每日最新資訊28at.com

輪詢的方式非常消耗CPU資源,阻塞的方式顯然與我們的異步初衷背道而馳。nkJ28資訊網(wǎng)——每日最新資訊28at.com

JDK8提供的CompletableFuture實現(xiàn)了Future接口,添加了很多Future不具備的功能,比如鏈式編程、異常處理回調(diào)函數(shù)、獲取異步結(jié)果不阻塞不輪詢、合并異步任務(wù)等。nkJ28資訊網(wǎng)——每日最新資訊28at.com

獲取異步線程結(jié)果后,我們可以通過添加事務(wù)的方式,實現(xiàn)Excel入庫操作的數(shù)據(jù)一致性。nkJ28資訊網(wǎng)——每日最新資訊28at.com

異步多線程情況下如何實現(xiàn)事務(wù)?nkJ28資訊網(wǎng)——每日最新資訊28at.com

有的小伙伴可能會說:nkJ28資訊網(wǎng)——每日最新資訊28at.com

這還不簡單?添加@Transactional注解,如果發(fā)生異常或入庫數(shù)據(jù)量不符,直接回滾就可以了~nkJ28資訊網(wǎng)——每日最新資訊28at.com

那么,真的是這樣嗎?我們下期見~nkJ28資訊網(wǎng)——每日最新資訊28at.com

本文鏈接:http://www.www897cc.com/showinfo-26-67849-0.html獲取雙異步返回值時,如何保證主線程不阻塞?

聲明:本網(wǎng)頁內(nèi)容旨在傳播知識,若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: Node問題:如何正確安裝nvm?Mac和Win雙教程!

下一篇: lowcode-cms開源社區(qū)源碼設(shè)計分享

標簽:
  • 熱門焦點
  • Find N3入網(wǎng):最高支持16+1TB

    OPPO將于近期登場的Find N3折疊屏目前已經(jīng)正式入網(wǎng),型號為PHN110。本次Find N3在外觀方面相比前兩代有很大的變化,不再是小號的橫向折疊屏,而是跟別的廠商一樣采用了較為常見的
  • 企業(yè)采用CRM系統(tǒng)的11個好處

    客戶關(guān)系管理(CRM)軟件可以為企業(yè)提供很多的好處,從客戶保留到提高生產(chǎn)力。  CRM軟件用于企業(yè)收集客戶互動,以改善客戶體驗和滿意度。  CRM軟件市場規(guī)模如今超過580
  • 新電商三兄弟,“抖快紅”成團!

    來源:價值研究所作 者:Hernanderz 隨著內(nèi)容電商的概念興起,抖音、快手、小紅書組成的&ldquo;新電商三兄弟&rdquo;成為業(yè)內(nèi)一股不可忽視的勢力,給阿里、京東、拼多多帶去了巨大壓
  • ESG的面子與里子

    來源 | 光子星球撰文 | 吳坤諺編輯 | 吳先之三伏大幕拉起,各地高溫預(yù)警不絕,但處于厄爾尼諾大&ldquo;烤&rdquo;之下的除了眾生,還有各大企業(yè)發(fā)布的ESG報告。ESG是&ldquo;環(huán)境保
  • 華為開發(fā)者大會2023日程公開:開設(shè)鴻蒙HarmonyOS 4體驗區(qū)

    IT之家 7 月 31 日消息,華為今日公布了 HDC.Together 開發(fā)者大會 2023 的詳細日程。整場大會將于 8 月 4 日-6 日之間舉行,屆時將發(fā)布最新一代鴻蒙 H
  • 2納米決戰(zhàn)2025

    集微網(wǎng)報道 從三強爭霸到四雄逐鹿,2nm的廝殺聲已然隱約傳來。無論是老牌勁旅臺積電、三星,還是誓言重回先進制程領(lǐng)先地位的英特爾,甚至初成立不久的新
  • 三星Galaxy Z Fold5官方渲染圖曝光:13.4mm折疊厚度依舊感人

    據(jù)官方此前宣布,三星將于7月26日在韓國首爾舉辦Unpacked活動,屆時將帶來帶來包括Galaxy Buds 3、Galaxy Watch 6、Galaxy Tab S9、Galaxy Z Flip 5、
  • 上海舉辦人工智能大會活動,建設(shè)人工智能新高地

    人工智能大會在上海浦江兩岸隆重拉開帷幕,人工智能新技術(shù)、新產(chǎn)品、新應(yīng)用、新理念集中亮相。8月30日晚,作為大會的特色活動之一的上海人工智能發(fā)展盛典人工
  • 三翼鳥智能家居亮相電博會,讓用戶體驗更真實

    2021電博會在青島國際會展中心開幕中,三翼鳥直接把“家”搬到了現(xiàn)場,成為了展會的一大看點。這也是三翼鳥繼9月9日發(fā)布了行業(yè)首個一站式定制智慧家平臺后的
Top 主站蜘蛛池模板: 玉林市| 衡南县| 兴业县| 新蔡县| 定结县| 新宾| 化德县| 原阳县| 离岛区| 来宾市| 齐齐哈尔市| 万宁市| 时尚| 财经| 东平县| 潮安县| 都兰县| 乌审旗| 汝城县| 宜城市| 那坡县| 滨州市| 稻城县| 五莲县| 福建省| 邳州市| 萍乡市| 宁国市| 休宁县| 金华市| 绿春县| 同德县| 乌恰县| 桃江县| 新泰市| 宜川县| 南通市| 洛扎县| 鄂尔多斯市| 东明县| 铜梁县|