From ee33a4a45efc660803068ba19844f82e177377a7 Mon Sep 17 00:00:00 2001 From: jishenghua <752718920@qq.com> Date: Tue, 19 Mar 2024 16:03:23 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4=E5=A4=9A=E4=BD=99=E7=9A=84?= =?UTF-8?q?=E6=B5=8B=E8=AF=95=E7=B1=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- jshERP-boot/src/test/java/ThreadPoolTest.java | 64 ------------------- .../src/test/java/com/jsh/erp/DepotTest.java | 35 ---------- 2 files changed, 99 deletions(-) delete mode 100644 jshERP-boot/src/test/java/ThreadPoolTest.java delete mode 100644 jshERP-boot/src/test/java/com/jsh/erp/DepotTest.java diff --git a/jshERP-boot/src/test/java/ThreadPoolTest.java b/jshERP-boot/src/test/java/ThreadPoolTest.java deleted file mode 100644 index bee31f89..00000000 --- a/jshERP-boot/src/test/java/ThreadPoolTest.java +++ /dev/null @@ -1,64 +0,0 @@ -import java.util.ArrayList; -import java.util.List; -import java.util.concurrent.Callable; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; -import java.util.concurrent.Future; - -/** - * 线程池测试案例 - */ -public class ThreadPoolTest { - - public static void main(String[] args) throws Exception { - // 开始时间 - long start = System.currentTimeMillis(); - List list = new ArrayList(); - for (int i = 1; i <= 3000; i++) { - list.add(i + ""); - } - // 每500条数据开启一条线程 - int threadSize = 500; - // 总数据条数 - int dataSize = list.size(); - // 线程数 - int threadNum = dataSize / threadSize + 1; - // 定义标记,过滤threadNum为整数 - boolean special = dataSize % threadSize == 0; - // 创建一个线程池 - ExecutorService exec = Executors.newFixedThreadPool(threadNum); - // 定义一个任务集合 - List> tasks = new ArrayList>(); - Callable task = null; - List cutList = null; - // 确定每条线程的数据 - for (int i = 0; i < threadNum; i++) { - if (i == threadNum - 1) { - if (special) { - break; - } - cutList = list.subList(threadSize * i, dataSize); - } else { - cutList = list.subList(threadSize * i, threadSize * (i + 1)); - } - final List listStr = cutList; - task = new Callable() { - @Override - public Integer call() throws Exception { - System.out.println(Thread.currentThread().getName() + "线程:" + listStr); - return 1; - } - }; - // 这里提交的任务容器列表和返回的Future列表存在顺序对应的关系 - tasks.add(task); - } - List> results = exec.invokeAll(tasks); - for (Future future : results) { - System.out.println(future.get()); - } - // 关闭线程池 - exec.shutdown(); - System.out.println("线程任务执行结束"); - System.err.println("执行任务消耗了 :" + (System.currentTimeMillis() - start) + "毫秒"); - } -} diff --git a/jshERP-boot/src/test/java/com/jsh/erp/DepotTest.java b/jshERP-boot/src/test/java/com/jsh/erp/DepotTest.java deleted file mode 100644 index b82dd2d8..00000000 --- a/jshERP-boot/src/test/java/com/jsh/erp/DepotTest.java +++ /dev/null @@ -1,35 +0,0 @@ -package com.jsh.erp; - -import com.alibaba.fastjson.JSON; -import com.jsh.erp.datasource.entities.Depot; -import com.jsh.erp.service.depot.DepotService; -import lombok.extern.slf4j.Slf4j; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.test.context.junit4.SpringRunner; -import javax.annotation.Resource; -import java.util.List; - -@Slf4j -@RunWith(SpringRunner.class) -@SpringBootTest -public class DepotTest { - - @Resource - private DepotService depotService; - - @Test - public void getDepot() throws Exception{ - Depot result = depotService.getDepot(1l); - log.info("depot result:" + JSON.toJSONString(result)); - } - - @Test - public void getAllList() throws Exception{ - List depotList =depotService.getAllList(); - log.info("depot result:" + JSON.toJSONString(depotList)); - } - - -}