Bagaimana untuk menggunakan Semaphore untuk melaksanakan pengehadan semasa di Jawa?

Konsep

1. Semaphore boleh dilihat sebagai semaphore yang telah diterjemahkan secara meluas kepada semaphore Secara konseptual, semaphore mengekalkan satu set kelayakan, dan benang yang memperoleh kelayakan boleh Mengakses sumber dan melepaskannya selepas digunakan Kami boleh menggunakan semaphore untuk mengehadkan utas serentak mengakses sumber tertentu.

2. Ia boleh diringkaskan secara ringkas sebagai: kaunter, giliran menunggu, tiga kaedah. Dalam model semaphore, kaunter dan giliran menunggu adalah telus dan hanya boleh diakses melalui tiga kaedah yang disediakan oleh model semaphore iaitu Internet, acquire dan release.

Contoh

public class SemaphoreDemo {
 
    static class Link {
    }
 
    static class ObjPool<T, R> {
 
        final List<T> pool;
 
        final Semaphore semaphore;
 
        ObjPool(int size, T t) {
            pool = new Vector<>(size);
            for (int i = 0; i < size; i++) {
                pool.add(t);
            }
            semaphore = new Semaphore(size);
        }
 
        public R exec(Function<T, R> func) throws Exception {
            T t = null;
            semaphore.acquire();
            try {
                System.out.println(Thread.currentThread().getName() + "---------争夺锁--------");
 
                t = pool.remove(0);
                System.out.println(Thread.currentThread().getName() + " 拿到锁执行");
                return func.apply(t);
            } finally {
                pool.add(t);
                semaphore.release();
            }
        }
    }
 
    public static void main(String[] args) {
        ObjPool objPool = new ObjPool(5, new Link());
        for (int i = 0; i < 30; i++) {
            new Thread(() -> {
                try {
                    objPool.exec(t -> t.toString());
                } catch (Exception e) {
                }
            }).start();
        }
    }
}

Atas ialah kandungan terperinci Bagaimana untuk menggunakan Semaphore untuk melaksanakan pengehadan semasa di Jawa?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!