线程池相关

àì夳堔傛蜴生んèń 2021-09-14 22:04 445阅读 0赞

1.通过使用Executor将处理请求任务的提交与它的执行体进行解耦。    
eg：

Java代码   [![收藏代码][icon_star.png]][icon_star.png 1]

1.  **import** java.net.ServerSocket;  
2.  **import** java.net.Socket;  
3.  **import** java.util.concurrent.Executor;  
4.  **import** java.util.concurrent.Executors;  
5.  /\*\* 
6.   \* 用Executor创建数量为100的线程池来构建简易的WebServer 
7.   \* @author yale 
8.   \* 
9.   \*/  
10. **public** **class** TaskExecutionWebServer  
11. \{  
12.     **private** **static** **final** **int** THREAD\_NUM = 100;// 定义线程池中线程数量  
13.   
14.     **private** **static** **final** Executor exec =   
15.             Executors.newFixedThreadPool(THREAD\_NUM);  
16.       
17.     **public** **static** **void** main(String\[\] args) **throws** Exception  
18.     \{  
19.         ServerSocket socket = **new** ServerSocket(80);  
20.           
21.         **while**(**true**)  
22.         \{  
23.             **final** Socket connection = socket.accept();  
24.               
25.             Runnable task = **new** Runnable()\{  
26.   
27.                 **public** **void** run()  
28.                 \{  
29.                     //handelRequest(connection);    
30.                       
31.                 \}  
32.                   
33.             \};  
34.             exec.execute(task);  
35.         \}  
36.     \}  
37.       
38.   
39. \}

注意:   
无论何时当你看到这种形式的代码：

Java代码   [![收藏代码][icon_star.png]][icon_star.png 1]

1.  **new** Thread(runnable).start();

并且你可能最终希望获得一个更加灵活的执行策略时，请认真考虑使用Executor代替Thread。

JDK 线程池   
Executors.newCachedThreadPool(); //带缓存的 不够时自动添加  
Executors.newSingleThreadExecutor(); //单个线程池  线程死掉后自动创建  
Executors.newFixedThreadPool(10);  //创建容纳N个线程的  
Executors.newScheduledThreadPool(19); //创建定时器线程池  
  
executo() 无返回结果  
submit()  有返回结果的线程  
  
Callable: //可返还结果的线程  
  
ExecutorService threadpol = Executors.newSingleThreadExecutor();  
Future<String> future = threadpol.submit(  
    new Callable<String>()\{  
        public String call()\{  
            return "aaaa";  
        \}  
    \}  
    system.out.print(Future.get());  
);  
  
  
Lock lock = new ReentrantLock(); //lock 对象  
Condition condition = lock.newCondition(); // 条件. 通讯对象  
condition.await(); //不是 object的 wait   
condition.signal(); //唤醒  
  
try\{  
    lock.lock();  
...  
\}finally\{  
    lock.unLock();  
\}  
  
ReentrantReadWriteLock rwl = ReentrantReadWriteLock(); //文件锁  
rwl.readLock().lock();  
rwl.writeLock().lock();  
  
条件等待尽量使用while()\{  
  
\}  
  
多线程关键字  
Executors.newCachedThreadPool(); //带缓存的 不够时自动添加  
Executors.newSingleThreadExecutor(); //单个线程池  死掉后再创建  
Executors.newFixedThreadPool(10);  //创建容纳N个线程的  
Executors.newScheduledThreadPool(19); //创建定时器线程池  
Lock lock = new ReentrantLock(); //lock 互斥锁 对象  
Condition condition = lock.newCondition(); // 条件. 通讯对象  
Condition        //条件锁  
Semaphore         //信号量 类似执行授权 (最多有3个人可以走)  
CyclicBarrier     //类似集合点 (必须3个人同时到才能走)  
CountDownLatch    //计数器 计时器效果 某时间点同时执行 CountDownLath a = new CountDownLath(1); a.await(); a.countDown();  
Exchanger        //数据交换 Exchanger a = new Exchanger()//放主线程; a.exchange("asd")

ArrayBlockingQueue            //阻塞队列  ArrayBlockingQueue 啊 = new ArrayBlockingQueue(); a.put(1);//阻塞 a.add(1);    //a.tack(); 获取

[icon_star.png]: http://onlyonetoone.iteye.com/images/icon_star.png
[icon_star.png 1]: /images/20210726/1329c37699da499287d66b962147c303.png