Java多线程服务器问题,executorservice的用法

创建了一个Java多线程服务器,通过socket连接不断接收大量设备(客户端)传输过来的信息

         // 创建可以容纳4个线程的线程池  
        ExecutorService fixedThreadPool = Executors.newFixedThreadPool(4);  

当连接数达到4个时出现了阻塞状态,求解怎么解决,怎么在完成一次数据解析后释放工作线程接收下一个连接,有点卡壳

3个回答

这是因为你的线程池只有4个线程,这样当4个线程都在工作的时候,你新来的任务就要阻塞等待其他线程完成工作才能进入工作状态。
你只要让你的工作线程函数完成任务后就返回,不要阻塞在里面

romanticRose
青春没有彩排丶 怎么解决阻塞问题呢
大约 3 年之前 回复

一个银行网点有四个窗口,每个窗口有一个业务员处理业务。你的业务员从设计上就不是一次性的,业务员会一直在窗口上等待业务,就算你的银行还有100个待命业务员,但是这100个业务员根本没机会上窗口。除非处理完一个业务就杀死一个业务员,然后空出柜台让下一个业务员上来,但是这样的设计没太大意义,因为你的窗口就四个,总是换业务员不会增加你这个银行网点的效率,反而会增加更换业务员的开销。如果你的线程池就四个位置,那就创建四个线程扔进去就好了

线程池大致会有三四种用法。
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(4);

你用的这种是堵塞性线程池,也就是当线程数量为4的时候,不会再产生新的线程,知道跑完一个后,才会产生新的线程去执行任务。

看你的留言事项解决堵塞。

可以尝试使用

ExecutorService cachedThreadPool = Executors.newCachedThreadPool(4);

这种用法是当有第五个线程任务来临的时候,会新new个线程去跑,从而解决堵塞。

在内存不大的情况下,容易导致内存溢出。

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
并发包里的ExecutorService线程池问题

我是web项目,ssh结构 页面发起一个请求,进action,然后进service,在service里执行ExecutorService es = Executors.newSingleThreadExecutor();开启一个单线程 我有两个问题: 1、在用户a请求时创建线程,当请求结束、线程执行完毕,线程会销毁吗?还是回到池里? 2、当a请求时,线程执行中,这是b也发起请求,此时还会开个线程吗?还是等待a的线程执行完才执行b的线程?

java多线程同时更新和查询数据库并发

java多线程 使用CompletionService提交异步任务,直接上代码 final int count = 1000; public static final ExecutorService executorService = Executors.newFixedThreadPool(3); public void deal(){ CompletionService cs = new ExecutorCompletionService(executorService); for(i=0;i<100;i++){ List<Object> datalist = dao.selectList("select * tableName where state = 0"); cs.submit(datalist) } CountDownLatch latch = new CountDownLatch(100); for(i=0;i<100;i++){ executorService.submit(()->{ dao.updateState(update tableName set state = 1 limit i,1); latch.countDown(); }); } latch.await(); if(count - 100 > 0){ //此处调用的全是和第一次的一模一样 deal(); } } 内层调用获取到的数据全部一模一样,尝试过加读写锁,都不生效,求助

关于java多线程操作invokeAll空指针的问题

求救各位大神: ``` public static void threadTestAll(String dirName) { long start = System.currentTimeMillis(); ExecutorService pool = Executors.newFixedThreadPool(30); List<Callable<String>> tasks = new ArrayList<Callable<String>>(); File dir = new File(dirName); for(File f:dir.listFiles(new myFilter())){ myTask t = new ThreadTest2().new myTask(f.getAbsolutePath()); tasks.add(t); } try { List<Future<String>> r = pool.invokeAll(tasks); for (Future<String> f : r) { if(f != null){ System.out.println(f); System.out.println("task result=" + f.get()); } } pool.shutdown(); long end = System.currentTimeMillis(); System.out.println("测试用了"+(end-start)+"毫秒"); } catch (Exception e) { System.out.println("here"); e.printStackTrace(); } } ``` ``` class myTask implements Callable<String> { final String fileName; public myTask(String fileName) { this.fileName = fileName; } @Override public String call() throws Exception { System.out.println("线程开始查找"+fileName); List<String> l = FileUtils.serachFileNames(fileName, "[七七电视www.77ds.com]蚁人TS清晰中字.mp4", false); if(l.size() != 0){ // System.out.println(l.get(0)); System.out.println(l.get(0)); return l.get(0); } return ""; // throw new Exception("没找到"); } } ``` 我的两段代码,没有发现任何有空指针异常的情况,单步调试也不知道哪出问题了,在这里 System.out.println(f); System.out.println("task result=" + f.get()); 打印也可以把对象打印出来,但不知道为啥,总有一个对象get的时候出错了,报空指针问题,求大神指教 这是结果 ``` 线程开始查找d:\$RECYCLE.BIN 线程开始查找d:\7450 线程开始查找d:\android 线程开始查找d:\360WiFi 线程开始查找d:\cha 线程开始查找d:\360Downloads 线程开始查找d:\maven 线程开始查找d:\opt 线程开始查找d:\Program Files (x86) 线程开始查找d:\DOWNLOAD 线程开始查找d:\RJ 线程开始查找d:\updateEdb 线程开始查找d:\work 线程开始查找d:\program 线程开始查找d:\kinggsoft 线程开始查找d:\Program Files 线程开始查找d:\迅雷下载 线程开始查找d:\shuju 线程开始查找d:\Youku Files 线程开始查找d:\System Volume Information 线程开始查找d:\备份 d:\迅雷下载\新建文件夹\[七七电视www.77ds.com]蚁人TS清晰中字.mp4 java.util.concurrent.FutureTask@6ef0eed6 task result= java.util.concurrent.FutureTask@bd05c81 task result= java.util.concurrent.FutureTask@1c691f36 task result= java.util.concurrent.FutureTask@398020cc task result= java.util.concurrent.FutureTask@ae94e92 task result= java.util.concurrent.FutureTask@5b2558d6 task result= java.util.concurrent.FutureTask@70eb7859 task result= java.util.concurrent.FutureTask@732a54f9 task result= java.util.concurrent.FutureTask@6030e280 task result= java.util.concurrent.FutureTask@296672d6 task result= java.util.concurrent.FutureTask@4fd54d6 task result= java.util.concurrent.FutureTask@13ccb029 task result= java.util.concurrent.FutureTask@63415de6 task result= java.util.concurrent.FutureTask@587bd9f2 task result= java.util.concurrent.FutureTask@2b21cc40 task result= java.util.concurrent.FutureTask@37e893df here java.util.concurrent.ExecutionException: java.lang.NullPointerException at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222) at java.util.concurrent.FutureTask.get(FutureTask.java:83) at codeTest.ThreadTest2.threadTestAll(ThreadTest2.java:48) at codeTest.ThreadTest2.main(ThreadTest2.java:30) Caused by: java.lang.NullPointerException at codeTest.ThreadTest2$myTask.call(ThreadTest2.java:91) at codeTest.ThreadTest2$myTask.call(ThreadTest2.java:1) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) ```

java 多线程中每个线程中new一个对象使用还是有问题,各位大神帮忙看看,什么原理

-//代码如下,启动多个线程,每个线程线程中 new Test1 使用,但是在Test1 的方法中打印大概率中存在重复的输入,请问这是为什么? package com; import java.util.ArrayList; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Semaphore; public class Test2 { public static void main(String[] args){ //System.out.println(System.getProperty("java.version")); //System.out.println(Math.random()); final String xmlhead1="xmlhead1"; final String xmlbody1="xmlbody1"; final String xmlhead2="xmlhead2"; final String xmlbody2="xmlbody2"; ExecutorService exec = Executors.newCachedThreadPool(); final Semaphore semp = new Semaphore(5); for (int index = 0; index < 1000; index++) { Runnable run = new Runnable() { public void run() { try { // 获取许可 semp.acquire(); if(Math.random()>=(0.5)){ Test1 testone=new Test1(); //synchronized (testone){ testone.parseString(xmlhead1, xmlbody1); //} } else{ Test1 testtwo=new Test1(); //synchronized (testtwo){ testtwo.parseString(xmlhead2, xmlbody2); //} } semp.release(); }catch(Exception e){ e.printStackTrace(); } } }; exec.execute(run); } exec.shutdown(); } } class Test1 { public String parseString(String head,String body){ System.out.println("parseString:"+this.toString()); return head+body; } }

java多线程 参数已经传入构造方法 进入run方法时参数却被改变

请教各位大神:我在for循环里面执行线程,遇到一个问题,代码如下: private static final ExecutorService executors = Executors.newScheduledThreadPool(10); ...... for(...){ executors.execute(new PublishThread(map)); } PublishThread实现了Runnable方法,它有一个私有成员变量map,在PublishThread有一个构造函数,接受了上面的map参数,并将它赋给私有成员变量map。调试的时候发现到构造函数里面时,map值与for循环里面传过来的值是匹配的,但是到run方法里面时,map里面的值却被改变。比如3次for循环传进的参数分别为:{classId=10295, class_ids=[10295, 10325, 10327]},{classId=10292, class_ids=[10292]},{classId=10293, class_ids=[10293]},但是3次run里面看到的值确是{classId=10295,, class_ids=[10293]},{classId=10292,, class_ids=[10293]},{classId=10293,, class_ids=[10293]},这已经不是顺序乱掉的问题(顺序乱本正常),而是变量里面乱了。请问这有可能是什么原因导致的呢?有什么措施可以让这个map不被改变?

java多线程,锁的问题

下面这段代码中,为什么会打印出奇数值并且退出,但是将注释去掉,程序就不会退出呢?求大神解答啊 package com.zy.test.lock; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class AtomicityTest implements Runnable { private int i = 0; public synchronized int getValue() { return i; } public synchronized void evenIncrement() { i++; // i++; } public void run() { while (true) { evenIncrement(); } } public static void main(String[] args) { ExecutorService service = Executors.newCachedThreadPool(); AtomicityTest test = new AtomicityTest(); service.execute(test); while (true) { int val = test.getValue(); if (val % 2 != 0) { System.out.println(val); System.exit(0); } } } }

通过线程将数据库读取的数据放在java队列,然后通过多线程处理数据的解决办法

各位大神,求帮助,我现在项目中有一个需求,对9张单表的有增删改的操作的时候 将数据通过单线程的方式放入java队列中,然后通过多线程的方式下发。我会建一张 下发失败的表,如果通过java队列下发失败了的数据会存入下发表,等待下次下发。 现在我做的是在这9张表有增、删、改、操作的时候通过队列管理器将数据放入队列中,然后用多线程的方式下发。 现在求助大家的是前面的步骤,就是队列管理器中的功能,也就是单线程放数据到队列中及通过队列多线程下发的步骤。由于小弟未在项目中真正的写过多线程的实例,特真心请求大神帮助,帮忙修改下代码的逻辑,小弟写了个初稿,肯定未完善,请大神帮忙完善下,多多考虑,非常感谢大家了! 以下是我初写的队列管理器的功能。请大神帮忙修改下,谢了 public class TaskQueueManage { public static BlockingQueue<Object> queue; private TaskQueueManage() { queue = new LinkedBlockingQueue<Object>(); } private static volatile TaskQueueManage instance; public static TaskQueueManage getIstance() { if (instance == null) { synchronized (TaskQueueManage.class) { if (instance == null) { instance = new TaskQueueManage(); } } } return instance; } //用线程将数据库中有增、删 、改操作的数据放入队列中 public static void put(final Object obj) { Runnable runnable = new Runnable() { @Override public void run() { try { //将读取的数据库的数据放入队列 queue.put(obj); } catch (Exception e) { } } }; Thread thread = new Thread(runnable); thread.start(); } //用多线程取出队列中的数据 public static void take() { //下发用线程池,将用多线程进行下发 ExecutorService service = Executors.newScheduledThreadPool(5); Runnable runnable = new Runnable() { @Override public void run() { try { Object obj = queue.take(); //取出数据,待操作.... } catch (Exception e) { } } }; service.equals(runnable); } } 真心求大家的帮助,谢谢了!

java多线程的程序设计

阅读和修改一个球的代码程序,完成多球的功能: Write a program that bounces balls inside a panel.The ball should begin moving with a mousePressed event. When user clocks the mouse, a ball should be added. When balls hits the edge of the panel,it should bounde off the edge and continue in the opposite direction. The ball location should be updated using Runnable. GUI as follows:![图片说明](https://img-ask.csdn.net/upload/201805/22/1526957953_416827.png) 程序如下: import java.util.Random; public class Ball implements Runnable { private int x; // horizontal position of ball private int y; // vertical position of ball private int dx; // change in horizontal position of ball private int dy; // change in vertical position of ball private final int MAX_X = 200; // horizontal edge of JPanel private final int MAX_Y = 200; // vertical edge of JPanel private static final Random generator = new Random(); public Ball(int xPos, int yPos) { dx = generator.nextInt(5) + 1; // change in x (1-5 pixels) dy = generator.nextInt(5) + 1; // change in y (1-5 pixels) x = xPos; // set ball to horizontal position of mouse press y = yPos; // set ball to vertical position of mouse press } // bounces ball perpetually until window is closed public void run() { while (true) {// infinite loop { try { Thread.sleep(20); // sleep for 20 milliseconds } // process InterruptedException during sleep catch (InterruptedException exception) { exception.printStackTrace(); } x += dx; // determine new x-position y += dy; // determine new y-position // if bounce off top or bottom of JPanel if (y <= 0 || y >= MAX_Y - 10) { dy = -dy; // reverse velocity in y direction } // if bounce off left or right of JPanel if (x <= 0 || x >= MAX_X - 10) { dx = -dx; // reverse velocity in x direction } } } // get horizontal position of ball public int getX() { return x; // return x value } // get vertical position of ball public int getY() { return y; // return y value } } import java.awt.Color; import java.awt.Dimension; import java.awt.Graphics; import java.awt.event.MouseEvent; import java.awt.event.MouseAdapter; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import javax.swing.JPanel; import javax.swing.JFrame; public class BallPanel extends JPanel { private Ball blueBall; // bouncing ball private ExecutorService threadExecutor; // for running Ball runnable private JFrame parentWindow; // parent window of JPanel private final int MAX_X = 200; // horizontal edge of JPanel private final int MAX_Y = 200; // vertical edge of JPanel public BallPanel(JFrame window) { parentWindow = window; // set parent window of JPanel // create ExecutorService for running ball runnable threadExecutor = Executors.newCachedThreadPool(); // anonymous inner class handles mouse events this.addMouseListener( new MouseAdapter() { public void mousePressed(MouseEvent event) { createBall(event); // delegate call to ball starter RepaintTimer timer = new RepaintTimer(parentWindow); threadExecutor.execute(timer); } } ); } // create a ball if no ball exists and set it in motion private void createBall(MouseEvent event) { if (blueBall == null) {// if no ball exists { int x = event.getX(); // get x position of mouse press int y = event.getY(); // get y position of mouse press blueBall = new Ball(x, y); // create new ball threadExecutor.execute(blueBall); // set ball in motion } } // return minimum size of animation public Dimension getMinimumSize() { return getPreferredSize(); } // return preferred size of animation public Dimension getPreferredSize() { return new Dimension(MAX_X, MAX_Y); } // draw ball at current position public void paintComponent(Graphics g) { super.paintComponent(g); if (blueBall != null) {// if ball exists { g.setColor(Color.blue); // set color to blue g.fillOval(blueBall.getX(), blueBall.getY(), 10, 10); // draws } } } import javax.swing.JFrame; public class BouncingBall extends JFrame { private final BallPanel ballCanvas; // JPanel in which ball bounces public BouncingBall() { ballCanvas = new BallPanel(this); // create new BallPanel add(ballCanvas); // add BallPanel to JFrame pack(); // make window just large enough for its GUI setVisible(true); // show window } public static void main(String args[]) { BouncingBall application = new BouncingBall(); application.setDefaultCloseOperation(EXIT_ON_CLOSE); } } import javax.swing.JFrame; public class RepaintTimer implements Runnable { private final JFrame repaintComponent; public RepaintTimer(JFrame frame) { // specify component to be repainted repaintComponent = frame; } public void run() { while (true) { try { Thread.sleep(20); } catch (InterruptedException ex) { ex.printStackTrace(); } repaintComponent.repaint(); // repaint the component } } }

java 中 ScheduledExecutorService 创建的多线程和 runnable

今天用到用ScheduledExecutorService 做定时任务,发现里面可以做多线程的操作。使用起来也很方便。 直接new 个实例就可以了。 ScheduledExecutorService executor = Executors .newScheduledThreadPool(10); for (int i = 0; i < 10; i++) { executor.scheduleAtFixedRate(new pop(), 0, 500, TimeUnit.MILLISECONDS); } 在for循环一个方法就可以了。 和以前使用runnable相比来说,结构简单点,并且使用也很方便。 想了解下scheduledExecutorService 和runnable 这两个之间的区别。和他们之间的差异、和使用场景

hibernate多线程插入数据无法进行

` public void addStockHistoryData() { StockCrawler sc = new StockCrawler(); ArrayList<String> codes = getAllStockCodes(); ExecutorService pool = Executors.newFixedThreadPool(100); CompletionService<ArrayList<StockHistoryData>> cs = new ExecutorCompletionService<ArrayList<StockHistoryData>>( pool); for (int i = codes.size() - 1; i > 800; i--) { String code = codes.get(i); cs.submit(new Callable<ArrayList<StockHistoryData>>() { @Override public ArrayList<StockHistoryData> call() throws Exception { System.out.println("getting " + code); ArrayList<StockHistoryData> sd = sc.getHistoryData(code, "300"); Session s = sessionFactory.openSession(); s.beginTransaction(); for (StockHistoryData d : sd) { s.saveOrUpdate(d); } s.getTransaction().commit(); s.close(); return sd; } }); } ` 这是多线程存数据的代码段,hibernate的show_sql设置为true,但是看到打印到某一句就停止执行了,也不报异常,怀疑是出现了死锁,但是不知道是什么操作可能导致这个问题?该怎么解决呢?

java 线程池中如何自定义每个线程名称

**java 线程池中如何自定义每个线程名称 java 线程池中如何自定义每个线程名称 **

java多线程报错 java.io.IOException: Stream closed

虽然程序可以正确的讲读取到的信息输出到文本文件 但是报错:java.io.IOException: Stream closed 不知道是什么原因 菜鸟请各位帮忙看一下 代码如下: package test; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; import java.util.Scanner; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class Test implements Runnable{ String lineString; public Test(String line){ this.lineString = line; } static FileWriter writer; static FileReader reader; public static void main(String[] args) throws IOException { try { reader = new FileReader("/Users/tcredit-0002/Desktop/car.txt"); Scanner scanner = new Scanner(reader); String lineString; writer = new FileWriter("/Users/tcredit-0002/Desktop/hebei.txt"); // TODO Auto-generated method stub ExecutorService pool = Executors.newFixedThreadPool(3); while(scanner.hasNext()){ lineString = scanner.nextLine(); pool.execute(new Test(lineString)); } scanner.close(); writer.close(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } @Override public void run() { try { writeResult(lineString); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public static synchronized void writeResult(String lineString) throws InterruptedException{ try { writer.write(lineString+"\r\n"); writer.flush(); System.out.println(lineString); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }

java多线程时程序运行完成为什么不会自动关闭退出?(木有钱了,求指教)

粘贴的大致代码如下: public static void main(String[] args) { int thread=0; ExecutorService pool = Executors.newFixedThreadPool(15);// 创建一个线程池 for (int i =666; i <= 888; i++) { for (int j = 0; j < 19; j++) { MyClass t =new MyClass(i,j);//某个继承了runnable的类,细节不重要 pool.execute(t); } }//外层for thread++; if(thread>=15){ //15个线程都运行结束了 pool.shutdown(); try { if (!pool.awaitTermination(60, TimeUnit.SECONDS)){ pool.shutdownNow(); } } catch (InterruptedException e) { pool.shutdownNow(); Thread.currentThread().interrupt(); } System.exit(0); } //每次运行时,等到功能完成了(如写入文件或打印),程序确实停止工作了,但就是不退出,即eclipse控制台红点没变灰,要手动结束才行。是代码的逻辑问题吗?

java web 多线程下载文件的问题。

**当我开启多线程下载文件时,outputstream.write 报 空指针 错误。 大佬们帮我看看 ** ``` ExecutorService executorService = Executors.newCachedThreadPool(); executorService.execute( new Runnable() { @Override public void run() { String path=System.getProperty("catalina.home")+"/webapps/uploadFiles/njhb/areaFiles/南京市/"+fileName; final File file = new File(path); if(!file.exists()){ System.out.println("文件不存在"); //response.setHeader("content-type", "text/html;charset=UTF-8"); response.setContentType("text/html;charset=UTF-8"); PrintWriter writer = null; try { writer = response.getWriter(); } catch (IOException e) { e.printStackTrace(); } writer.write("文件不存在!"); return; } response.reset(); response.setCharacterEncoding("UTF-8"); response.setContentType("multipart/form-data"); response.setHeader("Content-Disposition", "attachment;fileName="+ encodingFileName(fileName)); response.setHeader("Set-Cookie", "fileDownload=true; path=/;" + "attachment;fileName=" + encodingFileName(fileName)); try { //打开本地文件流 InputStream inputStream = new FileInputStream(file); //激活下载操作 OutputStream outputStream = response.getOutputStream(); //循环写入输出流 每次读取2048 一直读完 byte[] b = new byte[2048]; int length; int count=0; while ((length = inputStream.read(b)) > 0) { System.out.println("b: "+b+" length: "+length); outputStream.write(b, 0, length); count++; } // 这里主要关闭。 outputStream.close(); inputStream.close(); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); logg.info("文件下载终止!!!"); } } } ); ``` 下面是报错信息!! ![图片说明](https://img-ask.csdn.net/upload/201905/30/1559211144_987376.jpg)

java 后台线程中创建一个线程问题求解

今晚在看Think In Java的时候,看到后台线程这一小节,突然有个想法,如果在一个守护线程里面创建一个非守护线程(不显示的设置setDaemon(true)),那么创建的非守护线程是否也变成了守护线程。 代码如下 package com.hq.day0601; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; /** * 简单的后台线程(守护线程)练习,该练习主要演示的是后台线程在最后一个非后台线程结束后,也会被关闭 * @author Administrator * */ public class SimpleDaemons implements Runnable { <span style="white-space:pre"> </span>@Override <span style="white-space:pre"> </span>public void run() {<span style="white-space:pre"> </span> <span style="white-space:pre"> </span>try { <span style="white-space:pre"> </span>ExecutorService exec = Executors.newCachedThreadPool(); <span style="white-space:pre"> </span>exec.execute(new TestThread());<span style="white-space:pre"> </span> <span style="white-space:pre"> </span>TimeUnit.MILLISECONDS.sleep(100); <span style="white-space:pre"> </span>System.out.println("SimpleDaemons is Daemons:"+Thread.currentThread().isDaemon()); <span style="white-space:pre"> </span>System.out.println(Thread.currentThread() +" "+this ); <span style="white-space:pre"> </span> <span style="white-space:pre"> </span>} catch (InterruptedException e) {<span style="white-space:pre"> </span> <span style="white-space:pre"> </span>e.printStackTrace(); <span style="white-space:pre"> </span>System.out.println("sleep() Interrupted"); <span style="white-space:pre"> </span>}<span style="white-space:pre"> </span> <span style="white-space:pre"> </span>} <span style="white-space:pre"> </span> <span style="white-space:pre"> </span>public static void main(String[] args) throws Exception { <span style="white-space:pre"> </span>for(int i = 0 ; i < 3;i++){ <span style="white-space:pre"> </span>Thread daemons = new Thread(new SimpleDaemons()); <span style="white-space:pre"> </span>daemons.setDaemon(true); <span style="white-space:pre"> </span>daemons.start(); <span style="white-space:pre"> </span>} <span style="white-space:pre"> </span>System.out.println("daemons start!"); <span style="white-space:pre"> </span>TimeUnit.SECONDS.sleep(1); <span style="white-space:pre"> </span>} } /** * 校验守护线程中创建的线程是否是守护线程 * @author Administrator * */ class TestThread implements Runnable { <span style="white-space:pre"> </span>@Override <span style="white-space:pre"> </span>public void run() { <span style="white-space:pre"> </span>System.out.println("TestThread is Daemon:"+Thread.currentThread().isDaemon()); <span style="white-space:pre"> </span>} } 打印结果: 从打印结果观察到,在后台线程中创建的线程不是后台线程。 然后,我对代码进行了改造,加上while循环 代码如下: package com.hq.day0601; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; /** * 简单的后台线程(守护线程)练习,该练习主要演示的是后台线程在最后一个非后台线程结束后,也会被关闭 * @author Administrator * */ public class SimpleDaemons implements Runnable { @Override public void run() { try { ExecutorService exec = Executors.newCachedThreadPool(); exec.execute(new TestThread()); while(true){//添加while循环 TimeUnit.MILLISECONDS.sleep(100); System.out.println("SimpleDaemons is Daemons:"+Thread.currentThread().isDaemon()); System.out.println(Thread.currentThread() +" "+this ); } } catch (InterruptedException e) { e.printStackTrace(); System.out.println("sleep() Interrupted"); } } public static void main(String[] args) throws Exception { for(int i = 0 ; i < 3;i++){ Thread daemons = new Thread(new SimpleDaemons()); daemons.setDaemon(true); daemons.start(); } System.out.println("daemons start!"); TimeUnit.SECONDS.sleep(1); } } /** * 校验守护线程中创建的线程是否是守护线程 * @author Administrator * */ class TestThread implements Runnable { @Override public void run() { System.out.println("TestThread is Daemon:"+Thread.currentThread().isDaemon()); } } 我以为程序会在一秒后终止。但是却出了一个奇怪的现象,控制台一直在打印while循环里要打印的内容, 这让我感到非常费解,不知道有没有哪个大神讲解下这是什么原因。

socket多线程的问题

java当中socket多线程是怎样写可以将所有客户发来的消息数记录下来并显示给客户,客户当前跟服务器说的是第几句话,比如第一个客户:0:0:aa 服务器回复aa 第一个客户:1:1:bb 服务器回复bb 第二个客户:2:0:aa 服务器回复aa 第二个客户:3:1:bb 第一个数是总行数,第二个是当前客户行数第三个就是内容了现在这个程序已经完成了后两个,第一个总行数咋实现 谁给发个代码啥的谢谢最好能在这里加 package DemoServer; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.OutputStreamWriter; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.logging.Level; import java.util.logging.Logger; import java.util.logging.SocketHandler; import org.w3c.dom.css.Counter; public class Server { public static void main(String[] args) throws IOException { int port = 8821; ServerSocket serverSocket = new ServerSocket(port); ExecutorService exe = Executors.newFixedThreadPool( //只有一个ExecutorService,执行 Runtime.getRuntime().availableProcessors()*10); while(true) { Socket socket = serverSocket.accept(); exe.execute(getTask(socket)); //开启多个线程 } } public static Runnable getTask(final Socket s) { // Map<OutputStream, Integer> lines = new HashMap<OutputStream, Integer>(); return new Runnable(){ private BufferedReader br = null; private PrintWriter pw = null; private Socket socket = null; private int number = 0; // private int count; public void run() { try { this.socket = s; //socket可以传递 System.out.println("接收到客户端的数据"); br = getReader(socket); pw = getWriter(socket); //从客户端读 String msg = null; while (( msg = br.readLine()) != null) { System.out.println(msg); number++; pw.println(count +":" + number +":"+ msg); if(msg.equals("bye")) //注意,没有这句不能退出while break; } //向客户端写 pw.println("数据正确"); } catch (IOException ex) { Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex); } finally { try { if(socket!=null) socket.close(); } catch (IOException ex) { Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex); } } } //从客户端读数据 private BufferedReader getReader(Socket socket) throws IOException { InputStream input = socket.getInputStream(); return new BufferedReader(new InputStreamReader(input)); } //向客户端写数据 private PrintWriter getWriter(Socket socket) throws IOException { OutputStream output = socket.getOutputStream(); return new PrintWriter(new OutputStreamWriter(output),true);//注意true是提醒刷新 } }; } }

Java的线程问题互锁问题

我创建了两个线程,共同请求两个资源 Object1 和 Object2。线程1占用O1然后请求 O2;同理 线程2 占用 O2 请求 O1,为了防止线程一下子走完从而没有一直保持占用资源的状态,我还添加了一个倒计时。 可是当线程2明显占用了资源2的时候,线程1还是能够获取到资源2.请问这是为什么呢? ``` public class DeadLockThreadDemo { // 定义两个资源 public static Object resource01 = new Object(); public static Object resource02 = new Object(); public static void main(String[] args) { /*ExecutorService executorService = Executors .newFixedThreadPool(3, new MyThreadFactory("Gary Thread pool")); executorService.execute(new TakeResource1(resource01, resource02)); executorService.execute(new TakeResource2(resource01, resource02));*/ Thread thread1 = new Thread(new TakeResource1(resource01, resource02)); Thread thread2 = new Thread(new TakeResource2(resource01, resource02)); thread1.start(); thread2.start(); } } class TakeResource1 implements Runnable{ final Object resource1; final Object resource2; public TakeResource1(Object resource1, Object resource2) { this.resource1 = resource1.toString(); this.resource2 = resource2.toString(); } @Override public void run() { synchronized (resource1) { System.out.println("线程" + Thread.currentThread().getName() + " 占用资源 " + resource1 + " 请求 " +resource2 + " 线程状态:" + Thread.currentThread().getState()); synchronized (resource2) { System.out.println("线程" + Thread.currentThread().getName() + " 成功占用 " + resource2); } } } } class TakeResource2 implements Runnable{ final Object resource1; final Object resource2; public TakeResource2(Object resource1, Object resource2) { this.resource1 = resource1.toString(); this.resource2 = resource2.toString(); } @Override public void run() { synchronized (resource2) { System.out.println("线程" + Thread.currentThread().getName() + " 占用资源 " + resource2 + " 请求 " + resource1); try { for (int i = 10; i > 0; i--) { System.out.println(Thread.currentThread().getName() + " 线程占用了" + resource2 + " 开始休眠:" + i); Thread.sleep(1000); } } catch (InterruptedException e) { e.printStackTrace(); } synchronized (resource1) { System.out.println("线程" + Thread.currentThread().getName() + " 成功占用 " + resource1); } } } } ``` ![图片说明](https://img-ask.csdn.net/upload/202004/09/1586447786_731429.jpg)

多个多线程类按顺序执行

第一次玩多线程,看代码。 public class Test { public static void doSomthing(){ System.out.println("11111111111"); } public static void main(String[] args) { System.out.println("调用线程1方法..."); TestThread1 testThread1 = new TestThread1(); testThread1.doSomething(); System.out.println("调用线程2方法..."); TestThread2 testThread2 = new TestThread2(); testThread2.doSomething(); System.out.println("其他方法....."); doSomthing(); } } 需求是:main里面的3个方法,要按顺序执行。 public class TestThread1 implements Runnable{ public void doSomething(){ ThreadPool pool = new ThreadPool(); for (int i = 0; i < 10; i++) { pool.addThread(new TestThread1()); } pool.shutdonw(); } public void run() { System.out.println("这是线程1..."); try { Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); } } } TestThread1 和 TestThread2 是一样的。 public class ThreadPool { private Integer POOL_SIZE = 2; private ExecutorService pool = Executors.newFixedThreadPool(POOL_SIZE); private ThreadCallback callback = null; private ThreadMonitor monitor = null; public ThreadPool() { } public synchronized void addThread(Runnable thread) { pool.execute(thread); } public synchronized void setCallback(ThreadCallback callback) { if (monitor == null) { this.callback = callback; monitor = new ThreadMonitor(pool, callback); Thread thread = new Thread(monitor); thread.start(); } } public synchronized void shutdonw() { pool.shutdown(); } public synchronized boolean isTerminated() { return pool.isTerminated(); } } ThreadPool是别人写的, 求大神啊!~~ 需求是:main里面的3个方法,要按顺序执行。 就是 testThread1.doSomething(); 完成后执行testThread2.doSomething(); 完成后执行doSomthing();

就是多线程处理list;以下代码如何能保证list安全呢

package com.gray.test; import java.util.ArrayList; import java.util.List; import java.util.concurrent.*; public class ThreadTest { public static void main(String[] args) throws Exception { // 开始时间 long start = System.currentTimeMillis(); // 模拟数据List List<String> list = new ArrayList<String>(); for (int i = 0; i < 3000; i++) { list.add(i + ""); } ExecutorService exec = Executors.newFixedThreadPool(3); CountDownLatch doneSignal = new CountDownLatch(3); exec.execute(new PoiWriter(doneSignal,list,0,999)); exec.execute(new PoiWriter(doneSignal,list,1000,1999)); exec.execute(new PoiWriter(doneSignal,list,2000,2999)); doneSignal.await(); exec.shutdown(); System.out.println("执行任务消耗了 :" + (System.currentTimeMillis() - start) + "毫秒"); } protected static class PoiWriter implements Runnable { private CountDownLatch doneSignal; private List list; private int start; private int end; public PoiWriter(CountDownLatch doneSignal,List list, int start, int end) { this.doneSignal = doneSignal; this.start = start; this.list = list; this.end = end; } @Override public void run() { try { for (int i = start; i <= end ;i++) { list.set(i, Thread.currentThread().getName() +"<--------->" + list.get(i)); System.out.println(list.get(i)); } } catch (Exception e) { e.printStackTrace(); } finally { doneSignal.countDown(); } } } }

大学四年自学走来,这些私藏的实用工具/学习网站我贡献出来了

大学四年,看课本是不可能一直看课本的了,对于学习,特别是自学,善于搜索网上的一些资源来辅助,还是非常有必要的,下面我就把这几年私藏的各种资源,网站贡献出来给你们。主要有:电子书搜索、实用工具、在线视频学习网站、非视频学习网站、软件下载、面试/求职必备网站。 注意:文中提到的所有资源,文末我都给你整理好了,你们只管拿去,如果觉得不错,转发、分享就是最大的支持了。 一、电子书搜索 对于大部分程序员...

在中国程序员是青春饭吗?

今年,我也32了 ,为了不给大家误导,咨询了猎头、圈内好友,以及年过35岁的几位老程序员……舍了老脸去揭人家伤疤……希望能给大家以帮助,记得帮我点赞哦。 目录: 你以为的人生 一次又一次的伤害 猎头界的真相 如何应对互联网行业的「中年危机」 一、你以为的人生 刚入行时,拿着傲人的工资,想着好好干,以为我们的人生是这样的: 等真到了那一天,你会发现,你的人生很可能是这样的: ...

Java基础知识面试题(2020最新版)

文章目录Java概述何为编程什么是Javajdk1.5之后的三大版本JVM、JRE和JDK的关系什么是跨平台性?原理是什么Java语言有哪些特点什么是字节码?采用字节码的最大好处是什么什么是Java程序的主类?应用程序和小程序的主类有何不同?Java应用程序与小程序之间有那些差别?Java和C++的区别Oracle JDK 和 OpenJDK 的对比基础语法数据类型Java有哪些数据类型switc...

我以为我学懂了数据结构,直到看了这个导图才发现,我错了

数据结构与算法思维导图

String s = new String(" a ") 到底产生几个对象?

老生常谈的一个梗,到2020了还在争论,你们一天天的,哎哎哎,我不是针对你一个,我是说在座的各位都是人才! 上图红色的这3个箭头,对于通过new产生一个字符串(”宜春”)时,会先去常量池中查找是否已经有了”宜春”对象,如果没有则在常量池中创建一个此字符串对象,然后堆中再创建一个常量池中此”宜春”对象的拷贝对象。 也就是说准确答案是产生了一个或两个对象,如果常量池中原来没有 ”宜春” ,就是两个。...

技术大佬:我去,你写的 switch 语句也太老土了吧

昨天早上通过远程的方式 review 了两名新来同事的代码,大部分代码都写得很漂亮,严谨的同时注释也很到位,这令我非常满意。但当我看到他们当中有一个人写的 switch 语句时,还是忍不住破口大骂:“我擦,小王,你丫写的 switch 语句也太老土了吧!” 来看看小王写的代码吧,看完不要骂我装逼啊。 private static String createPlayer(PlayerTypes p...

Linux面试题(2020最新版)

文章目录Linux 概述什么是LinuxUnix和Linux有什么区别?什么是 Linux 内核?Linux的基本组件是什么?Linux 的体系结构BASH和DOS之间的基本区别是什么?Linux 开机启动过程?Linux系统缺省的运行级别?Linux 使用的进程间通信方式?Linux 有哪些系统日志文件?Linux系统安装多个桌面环境有帮助吗?什么是交换空间?什么是root帐户什么是LILO?什...

Linux命令学习神器!命令看不懂直接给你解释!

大家都知道,Linux 系统有非常多的命令,而且每个命令又有非常多的用法,想要全部记住所有命令的所有用法,恐怕是一件不可能完成的任务。 一般情况下,我们学习一个命令时,要么直接百度去搜索它的用法,要么就直接用 man 命令去查看守冗长的帮助手册。这两个都可以实现我们的目标,但有没有更简便的方式呢? 答案是必须有的!今天给大家推荐一款有趣而实用学习神器 — kmdr,让你解锁 Linux 学习新姿势...

和黑客斗争的 6 天!

互联网公司工作,很难避免不和黑客们打交道,我呆过的两家互联网公司,几乎每月每天每分钟都有黑客在公司网站上扫描。有的是寻找 Sql 注入的缺口,有的是寻找线上服务器可能存在的漏洞,大部分都...

史上最全的 python 基础知识汇总篇,没有比这再全面的了,建议收藏

网友们有福了,小编终于把基础篇的内容全部涉略了一遍,这是一篇关于基础知识的汇总的文章,请朋友们收下,不用客气,不过文章篇幅肯能会有点长,耐心阅读吧爬虫(七十)多进程multiproces...

讲一个程序员如何副业月赚三万的真实故事

loonggg读完需要3分钟速读仅需 1 分钟大家好,我是你们的校长。我之前讲过,这年头,只要肯动脑,肯行动,程序员凭借自己的技术,赚钱的方式还是有很多种的。仅仅靠在公司出卖自己的劳动时...

女程序员,为什么比男程序员少???

昨天看到一档综艺节目,讨论了两个话题:(1)中国学生的数学成绩,平均下来看,会比国外好?为什么?(2)男生的数学成绩,平均下来看,会比女生好?为什么?同时,我又联想到了一个技术圈经常讨...

85后蒋凡:28岁实现财务自由、34岁成为阿里万亿电商帝国双掌门,他的人生底层逻辑是什么?...

蒋凡是何许人也? 2017年12月27日,在入职4年时间里,蒋凡开挂般坐上了淘宝总裁位置。 为此,时任阿里CEO张勇在任命书中力赞: 蒋凡加入阿里,始终保持创业者的冲劲,有敏锐的...

总结了 150 余个神奇网站,你不来瞅瞅吗?

原博客再更新,可能就没了,之后将持续更新本篇博客。

副业收入是我做程序媛的3倍,工作外的B面人生是怎样的?

提到“程序员”,多数人脑海里首先想到的大约是:为人木讷、薪水超高、工作枯燥…… 然而,当离开工作岗位,撕去层层标签,脱下“程序员”这身外套,有的人生动又有趣,马上展现出了完全不同的A/B面人生! 不论是简单的爱好,还是正经的副业,他们都干得同样出色。偶尔,还能和程序员的特质结合,产生奇妙的“化学反应”。 @Charlotte:平日素颜示人,周末美妆博主 大家都以为程序媛也个个不修边幅,但我们也许...

MySQL数据库面试题(2020最新版)

文章目录数据库基础知识为什么要使用数据库什么是SQL?什么是MySQL?数据库三大范式是什么mysql有关权限的表都有哪几个MySQL的binlog有有几种录入格式?分别有什么区别?数据类型mysql有哪些数据类型引擎MySQL存储引擎MyISAM与InnoDB区别MyISAM索引与InnoDB索引的区别?InnoDB引擎的4大特性存储引擎选择索引什么是索引?索引有哪些优缺点?索引使用场景(重点)...

新一代神器STM32CubeMonitor介绍、下载、安装和使用教程

关注、星标公众号,不错过精彩内容作者:黄工公众号:strongerHuang最近ST官网悄悄新上线了一款比较强大的工具:STM32CubeMonitor V1.0.0。经过我研究和使用之...

如果你是老板,你会不会踢了这样的员工?

有个好朋友ZS,是技术总监,昨天问我:“有一个老下属,跟了我很多年,做事勤勤恳恳,主动性也很好。但随着公司的发展,他的进步速度,跟不上团队的步伐了,有点...

我入职阿里后,才知道原来简历这么写

私下里,有不少读者问我:“二哥,如何才能写出一份专业的技术简历呢?我总感觉自己写的简历太烂了,所以投了无数份,都石沉大海了。”说实话,我自己好多年没有写过简历了,但我认识的一个同行,他在阿里,给我说了一些他当年写简历的方法论,我感觉太牛逼了,实在是忍不住,就分享了出来,希望能够帮助到你。 01、简历的本质 作为简历的撰写者,你必须要搞清楚一点,简历的本质是什么,它就是为了来销售你的价值主张的。往深...

大学一路走来,学习互联网全靠这几个网站,最终拿下了一把offer

大佬原来都是这样炼成的

离职半年了,老东家又发 offer,回不回?

有小伙伴问松哥这个问题,他在上海某公司,在离职了几个月后,前公司的领导联系到他,希望他能够返聘回去,他很纠结要不要回去? 俗话说好马不吃回头草,但是这个小伙伴既然感到纠结了,我觉得至少说明了两个问题:1.曾经的公司还不错;2.现在的日子也不是很如意。否则应该就不会纠结了。 老实说,松哥之前也有过类似的经历,今天就来和小伙伴们聊聊回头草到底吃不吃。 首先一个基本观点,就是离职了也没必要和老东家弄的苦...

为什么你不想学习?只想玩?人是如何一步一步废掉的

不知道是不是只有我这样子,还是你们也有过类似的经历。 上学的时候总有很多光辉历史,学年名列前茅,或者单科目大佬,但是虽然慢慢地长大了,你开始懈怠了,开始废掉了。。。 什么?你说不知道具体的情况是怎么样的? 我来告诉你: 你常常潜意识里或者心理觉得,自己真正的生活或者奋斗还没有开始。总是幻想着自己还拥有大把时间,还有无限的可能,自己还能逆风翻盘,只不是自己还没开始罢了,自己以后肯定会变得特别厉害...

什么时候跳槽,为什么离职,你想好了么?

都是出来打工的,多为自己着想

为什么程序员做外包会被瞧不起?

二哥,有个事想询问下您的意见,您觉得应届生值得去外包吗?公司虽然挺大的,中xx,但待遇感觉挺低,马上要报到,挺纠结的。

当HR压你价,说你只值7K,你该怎么回答?

当HR压你价,说你只值7K时,你可以流畅地回答,记住,是流畅,不能犹豫。 礼貌地说:“7K是吗?了解了。嗯~其实我对贵司的面试官印象很好。只不过,现在我的手头上已经有一份11K的offer。来面试,主要也是自己对贵司挺有兴趣的,所以过来看看……”(未完) 这段话主要是陪HR互诈的同时,从公司兴趣,公司职员印象上,都给予对方正面的肯定,既能提升HR的好感度,又能让谈判气氛融洽,为后面的发挥留足空间。...

面试阿里p7,被按在地上摩擦,鬼知道我经历了什么?

面试阿里p7被问到的问题(当时我只知道第一个):@Conditional是做什么的?@Conditional多个条件是什么逻辑关系?条件判断在什么时候执...

你期望月薪4万,出门右拐,不送,这几个点,你也就是个初级的水平

先来看几个问题通过注解的方式注入依赖对象,介绍一下你知道的几种方式@Autowired和@Resource有何区别说一下@Autowired查找候选者的...

面试了一个 31 岁程序员,让我有所触动,30岁以上的程序员该何去何从?

最近面试了一个31岁8年经验的程序猿,让我有点感慨,大龄程序猿该何去何从。

大三实习生,字节跳动面经分享,已拿Offer

说实话,自己的算法,我一个不会,太难了吧

程序员垃圾简历长什么样?

已经连续五年参加大厂校招、社招的技术面试工作,简历看的不下于万份 这篇文章会用实例告诉你,什么是差的程序员简历! 疫情快要结束了,各个公司也都开始春招了,作为即将红遍大江南北的新晋UP主,那当然要为小伙伴们做点事(手动狗头)。 就在公众号里公开征简历,义务帮大家看,并一一点评。《启舰:春招在即,义务帮大家看看简历吧》 一石激起千层浪,三天收到两百多封简历。 花光了两个星期的所有空闲时...

立即提问
相关内容推荐