怎样看redis 任务队列的任务执行数目

Posted 2023-05-07

参考技术A 您好，BRPOP命令接收两个参数，第一个是键名，第二个是超时时间，单位是秒。当超过了此时间仍然没有获得新元素的话就会返回nil。上例中超时时间为"0"，表示不限制等待的时间，即如果没有新元素加入列表就会永远阻塞下去。
当获得一个元素后BRPOP命令返回两个值，分别是键名和元素值。为了测试BRPOP命令，我们可以打开两个redis-cli实例，在实例A中：
redis A> BRPOP queue 0

键入回车后实例1会处于阻塞状态，这时在实例B中向queue中加入一个元素：
redis B> LPUSH queue task (integer) 1

在LPUSH命令执行后实例A马上就返回了结果：
1) "queue" 2) "task"

同时会发现queue中的元素已经被取走：
redis> LLEN queue (integer) 0

除了BRPOP命令外，Redis还提供了BLPOP，和BRPOP的区别在与从队列取元素时BLPOP会从队列左边取。本回答被提问者和网友采纳

JUC--自定义线程池

自定义线程线程池

如果当前线程池中的线程数目小于corePoolSize，则每来一个任务，就会创建一个线程去执行这个任务；如果当前线程池中的线程数目>=corePoolSize，则每来一个任务，会尝试将其添加到任务缓存队列当中，若添加成功，则该任务会等待空闲线程将其取出去执行；若添加失败（一般来说是任务缓存队列已满），则会尝试创建新的线程去执行这个任务；如果队列已经满了，则在总线程数不大于maximumPoolSize的前提下，则创建新的线程 如果当前线程池中的线程数目达到maximumPoolSize，则会采取任务拒绝策略进行处理；如果线程池中的线程数量大于 corePoolSize时，如果某线程空闲时间超过keepAliveTime，线程将被终止，直至线程池中的线程数目不大于corePoolSize；如果允许为核心池中的线程设置存活时间，那么核心池中的线程空闲时间超过keepAliveTime，线程也会被终止。

这是上篇文章讲到的 线程池原理 https://blog.csdn.net/qq_41977838/article/details/105918233

下面我们利用原理自定义一个线程池

 
   
   
 

  
    
    
  
public class Test0007 {
  
    
    
  


  
    
    
  
 public static void main(String[] args) {
  
    
    
  
 ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 2, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(3));
  
    
    
  
 for (int i = 1; i <= 6; i++) {
  
    
    
  
 TaskThred t1 = new TaskThred("任务" + i);
  
    
    
  
 executor.execute(t1);
  
    
    
  
 }
  
    
    
  
 executor.shutdown();
  
    
    
  
 }
  
    
    
  
}
  
    
    
  


  
    
    
  
class TaskThred implements Runnable {
  
    
    
  
 private String taskName;
  
    
    
  


  
    
    
  
 public TaskThred(String taskName) {
  
    
    
  
 this.taskName = taskName;
  
    
    
  
 }
  
    
    
  


  
    
    
  
 @Override
  
    
    
  
 public void run() {
  
    
    
  
 System.out.println(Thread.currentThread().getName()+taskName);
  
    
    
  
 }
  
    
    
  


  
    
    
  
}
 
   
   
 

通过线程池原理我们就可以实现一个简单的自定义线程池

1. 我们直接实现 new ThreadPoolExecutor(1, 2, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(3)); （详解：ThreadPoolExecutor 底层实现线程池方法，1：核心线程数，2：最大线程数，60L ：线程没有任务执行时最多保持多久时间会终止，TimeUnit.SECONDS：底层实现，表示一秒为单位，new ArrayBlockingQueue<>(3) ：ArrayBlockingQueue是一个阻塞式的队列，传入队列个数 ）

2. 调用 executor.execute(t1);

3. 结束 executor.shutdown();