Java线程同步栈Stack最新的LinkedBlockingDeque

客官°小女子只卖身不卖艺 2024-02-19 20:05 20阅读 0赞

## Java线程同步栈Stack最新的LinkedBlockingDeque ##

自Java 1.2开始，Java官方建议开发者不要使用Vector，为此受影响的还有Stack，因为Stack直接继承自Vector。尤其是，如果遇到线程同步栈的开发场景，可以考虑Java新式的BlockingDeque。BlockingDeque是一个双向的“队列”，它既可以作为FIFO的队列使用，也可以作为FILO的栈使用。如果把BlockingDeque当做FILO栈使用：

import java.util.concurrent.LinkedBlockingDeque;
    import java.util.concurrent.TimeUnit;
    
    public class Main {
        public static void main(String[] args) {
            Main main = new Main();
            try {
                main.test();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        private void test() throws Exception {
            LinkedBlockingDeque<Integer> deque = new LinkedBlockingDeque<>();
    
            //消费。数据出栈。
            new Thread(new Runnable() {
                @Override
                public void run() {
                    //一直不停的消费。数据出栈。
                    while (true) {
                        try {
                            //如果当前没有数据，则会进入阻塞。
                            System.out.println("出栈:" + deque.take());
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                    }
                }
            }).start();
    
            //生产。
            new Thread(new Runnable() {
                @Override
                public void run() {
                    int i = 0;
                    int a, b, c;
                    while (true) {
                        try {
                            TimeUnit.SECONDS.sleep(1);
    
                            a = i++;
                            b = i++;
                            c = i++;
    
                            System.out.println("入栈:->" + a + "->" + b + "->" + c);
    
                            deque.push(a);
                            deque.push(b);
                            deque.push(c);
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                    }
                }
            }).start();
        }
    }

输出：

入栈:->0->1->2
    出栈:2
    出栈:1
    出栈:0
    入栈:->3->4->5
    出栈:5
    出栈:4
    出栈:3
    入栈:->6->7->8
    出栈:8
    出栈:7
    出栈:6
    入栈:->9->10->11
    出栈:11
    出栈:10
    出栈:9
    入栈:->12->13->14
    出栈:14
    出栈:13
    出栈:12