首先,看下总的结构:


java.util.concurrent下线程池总结(1)
 


Executors类,提供了一系列工厂方法用于创先线程池,返回的线程池都实现了ExecutorService接口。

public static ExecutorService newFixedThreadPool(int nThreads)

创建固定数目线程的线程池。

public static ExecutorService newCachedThreadPool()

创建一个可缓存的线程池,调用execute 将重用以前构造的线程(如果线程可用)。

如果现有线程没有可用的,则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。

public static ExecutorService newSingleThreadExecutor()

创建一个单线程化的Executor。

public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)

创建一个支持定时及周期性的任务执行的线程池,多数情况下可用来替代Timer类。


public class Executors_1 extends Thread { String name ; public Executors_1(String name) { super(name); this.name = name; } @Override public void run() { int i = 0; while(i < 3){ System.out.println(name + " run :" + i); i++; } } public static void main(String[] args) throws Exception { ExecutorService es = Executors.newFixedThreadPool(1); for(int i = 0; i < 4; i++){ es.execute(new Executors_1(String.valueOf(i))); } TimeUnit.SECONDS.sleep(4L); es.shutdown(); ScheduledExecutorService ses = Executors.newScheduledThreadPool(1); ScheduledFuture<?> sf = ses.scheduleAtFixedRate(new Executors_1(String.valueOf("scheduler")), 10 , 10, TimeUnit.SECONDS); // 延迟10秒运行,每10秒运行一次 TimeUnit.SECONDS.sleep(30L); sf.cancel(true); // 中断sf } }

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-11-20
  • 2021-08-23
猜你喜欢
  • 2021-11-27
  • 2021-05-24
  • 2021-10-26
  • 2021-07-28
  • 2021-12-17
相关资源
相似解决方案