SocketListenerPusher.java代码如下:  Java代码   import java.io.IOException;   import&nb…

什么是线程池： 线程池就是控制线程的一个池子。用来控制线程数量。 为什么要使用线程池： 1.避免系统反复创建和销毁线程影响执行的时间（创建+销毁>>执行时间时） 2.控制线程数量。线程过多会导致机器执行卡（大…

这次这个的思路是在主类中维护一个map，map的key是线程名，value是线程的状态，然后创建周期执行的线程通过检测这个map来判断进程的状态，如果有死亡的进程就把该进程启动。 首先是主类，这里的main方法中为了执行…

一、线程池的作用 　　平时的业务中，如果要使用多线程，那么我们会在业务开始前创建线程，业务结束后，销毁线程。但是对于业务来说，线程的创建和销毁是与业务本身无关的，只关心线程所执行的任务。因此希望把尽可能多的cpu用在执行…

一、 在线程中运行任务 无限制创建线程的不足 .线程生命周期的开销很高 .资源消耗 .稳定性 二、Executor框架 Executor基于生产者-消费者模式。提交任务的操作相当于生产者。运行任务的线程则相当于消费者。 …

一.一个实现了Runnable接口的类 class MyThread implements Runnable{ private static int num = 0; @Override public void run(…

一、继承Thread类 public class Demo1 extends Thread { public Demo1(String name) { super(name); } @Override public vo…

文件读取和操作类 import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; public class Te…

原文地址： http://lib.csdn.net/article/scala/26722   一、Java方式开发 1、开发前准备 假定您以搭建好了Spark集群。 2、开发环境采用eclipse maven…

public ThreadPoolExecutor(int corePoolSize,                   &nb…

从 17 年的大三暑假就在这家公司实习转正，在这家公司呆了快2年了，随着公司新一轮的融资，看起来公司离上市更近了一步，但期权池也进一步稀释，没有期权的我感觉回报更少了，另外在这家公司接触到的东西也有瓶颈了，工作也非常轻松…

　　基于AQS的前世今生，来学习并发工具类Semaphore。本文将从Semaphore的应用场景、源码原理解析来学习这个并发工具类。 1、 应用场景 　　Semaphore用来控制同时访问某个特定资源的操作数量，或者同…