zoukankan      html  css  js  c++  java
  • 开启9个线程执行任务,但是同时只能有3个线程处于可运行状态,其余的暂时处于阻塞状态

    开启了9个线程分别取去执行任务,但同时只能有3个线程处于运行中,其余的处于block状态,等某个线程运行完后,再将block状态的线程唤醒去执行,直到所有的任务执行完成,这样做的一个原因是当系统中有大量线程,比如有10000个线程在运行时,CPU在线程之间切换可能导致效率很低,我只让有限的线程比如10个线程运行,减少线程间切换,可以提高效率。要求不使用线程池实现

    public class Test {
        //CONTROLS锁
        final static private LinkedList<Control> CONTROLS = new LinkedList<>();
        private final static int MAX_WORKER = 2;
    
        public static void main(String[] args) {
    
            List<Thread> worker = new ArrayList<>();
            Arrays.asList("T1", "T2", "T3", "T4", "T5", "T6", "T7", "T8", "T9").stream()
                    .map(Test::createCaptureThread).forEach(t -> {
                        t.start();
                        worker.add(t);
                    });
    
            worker.stream().forEach(t -> {
                try {
                    t.join();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
            System.out.println("All of capture work finished");
        }
    
        private static Thread createCaptureThread(String name) {
            return new Thread(() -> {
                System.out.println("The worker 【" + Thread.currentThread().getName() + " 】 BEGIN capture data ");
                synchronized (CONTROLS) {
                    while (CONTROLS.size() >  MAX_WORKER) {
                        try {
                            CONTROLS.wait();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    CONTROLS.addLast(new Control());
                }
                System.out.println("The worker 【" + Thread.currentThread().getName() + " 】  is working ...");
                try {
                    Thread.sleep(10000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
    
                synchronized (CONTROLS) {
                    System.out.println("The worker 【" + Thread.currentThread().getName() + " 】  END capture data ");
                    CONTROLS.removeFirst();
                    CONTROLS.notifyAll();
                }
            }, name);
        }
    
        private static class Control {
        }
    }
  • 相关阅读:
    《代码整洁之道》之四 注释
    《代码整洁之道》之三 函数
    《代码整洁之道》之二 有意义的命名
    《代码整洁之道》
    Hibernate学习笔记
    Struts2复习笔记
    学习Spring必学的Java基础知识
    Eclipse下搭建Maven框架
    onvif实现
    rtmp服务端实现
  • 原文地址:https://www.cnblogs.com/moris5013/p/10717422.html
Copyright © 2011-2022 走看看