线程池 -凯发k8国际

zw7534313

浏览: 1231614 次
性别:
来自: 北京

博主相关

博客

微博

相册

文章分类

社区版块

( 0)
( 21)
( 1)

存档分类

2023-12 ( 11)
2023-08 ( 10)
2022-08 ( 1)

线程池

博客分类：

java

线程池

//线程池: 只是按初始线程数执行任务，并没有创建新的工作者线程(take给阻塞了，影响吞吐量)
public class threadpool {

//任务队列
private blockingqueue queue = new linkedblockingqueue();

private int poolsize; //初始线程数
private int maxpoolsize; //最大线程数
private int size = 0; //线程数

//运行线程数：工作者
private list works = new arraylist();
private boolean isshutdown = false; //线程池状态
private timer timer;

public threadpool(int poolsize,int maxpoolsize) {
  this.poolsize = poolsize;
  this.maxpoolsize = maxpoolsize;
  init();
}

//初始化一些工作者
private void init() {
  worker w = null;
  for(int i=0;i   w = createthread();
   works.add(w);
  }
}

//创建工作者
private worker createthread() {
  worker w = new worker();
  thread t = new thread(w);
  t.setname("t" size);
  w.thread = t;
  t.start();
  size ;
  return w;
}

private worker createthread(runnable task) {
  worker w = new worker(task);
  thread t = new thread(w);
  t.setname("t" size);
  w.thread = t;
  t.start();
  size ;
  return w;
}

//提交任务
public void execute(runnable task) {
  system.out.println("execute..");
  try {
   if(size <= poolsize) { //放入队列
    queue.offer(task, 10, timeunit.seconds);
   }else if(size    worker w = createthread();
    works.add(w);
   }else { //拒绝任务
    reject(task);
   }
  } catch (interruptedexception e) {
   e.printstacktrace();
  } catch(exception e) {
   e.printstacktrace();
  }
}

//拒绝任务
private void reject(runnable task) throws exception{
  throw new exception("无法提交");
}

//获取任务
public runnable gettask() {

//  if(!queue.isempty()) {
   try {
    return queue.take();
   } catch (interruptedexception e) {
    e.printstacktrace();
   }
//  }
  //没有任务，工作者线程自动终止
  return null;
}

public void shutdown() {
  this.isshutdown = true;
  //终止工作者线程
  //使用定时器检测线程池的任是否全部执行完，如果执行完就终止线程
  timer = new timer();
  timer.schedule(new timertaskimpl(), 30*1000);
}

private class worker implements runnable{
  private runnable firsttask;
  private thread thread;

  public worker() {

  }

  public worker(runnable task) {
   system.out.println("创建新的工作者线程..");
   this.firsttask = task;
  }

  public void run() {
   system.out.println("worker ..");
   runnable task = null;
   if(firsttask != null) {
    task = firsttask;
    firsttask = null;
   }
   while(task!=null || (task=gettask())!=null) {
    task.run();
    system.out.println(thread.getname());
    task = null;
   }
  }

  //终止线程
  public void interrupt() {
   if(thread.currentthread()!=thread) {
    thread.interrupt();
   }
  }
}

//任务
static class task implements runnable{
static int i = 0;

  public void run() {
   system.out.println((i ) " hello");
   try {
    thread.sleep(1000);
   } catch (interruptedexception e) {
    e.printstacktrace();
   }
  }
}

//定时任务：关闭工作者线程
class timertaskimpl extends timertask{

  public void run() {
   if(isshutdown && queue.isempty()) {
     for(worker w: works) {
      w.interrupt();
     }
     timer.cancel();
   }
   system.out.println("定时器任务..");
  }
}

public static void main(string[] args) {
//  threadpool pool = new threadpool(1,2);
//  for(int i=0;i<2;i ) {
//   task task = new task();
//   pool.execute(task);
//  }

  threadpool pool = new threadpool(3,10);
  for(int i=0;i<20;i ) {
   task task = new task();
   pool.execute(task);
  }
  pool.shutdown();

}
}

0
顶

0
踩

分享到：

2018-04-16 08:52
浏览 936
评论(0)
分类:编程语言

发表评论

您还没有登录,请您登录后再发表评论

线程池 -凯发k8国际

最近访客

博主相关

文章分类

社区版块

存档分类

最新评论

线程池

评论

发表评论

相关推荐

线程池 -凯发k8国际

最近访客

博主相关

文章分类

社区版块

存档分类

最新评论

线程池

评论

发表评论

相关推荐

服务端推送multipart/x-mixed-replace