多线程-交替打印FooBar(Exchanger+Semaphore)

待我称王封你为后i 2022-09-13 13:21 155阅读 0赞

package com.ctl;
    
    import java.util.concurrent.Exchanger;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    
    /**
     * <p>Title: Test</p>
     * <p>Description: </p>
     * <p>Copyright: Copyright (c) 2019</p>
     * <p>Company: www.hanshow.com</p>
     *
     * @author ctl
     * @version 1.0
     * @date 2021-09-27 19:37
     */
    public class Test2 {
        static Semaphore semaphore = new Semaphore(1);
    
        static class Bar implements Runnable {
            private int times;
            private Exchanger<String> exchanger;
    
            public Bar(int times, Exchanger exchanger) {
                this.times = times;
                this.exchanger = exchanger;
            }
    
            @Override
            public void run() {
                for (int i = 0; i < times; i++) {
                    try {
                        exchanger.exchange("");
                        try {
                            semaphore.acquire();
                        } catch (Exception e) {
                        }
                        System.out.println("bar");
                    } catch (Exception e) {
                    }
                }
            }
        }
    
        static class Foo implements Runnable {
            private int times;
            private Exchanger<String> exchanger;
    
            public Foo(int times, Exchanger exchanger) {
                this.times = times;
                this.exchanger = exchanger;
            }
    
            @Override
            public void run() {
                for (int i = 0; i < times; i++) {
                    try {
                        exchanger.exchange("");
                        System.out.print("foo");
                        semaphore.release();
                    } catch (Exception e) {
                    }
                }
            }
        }
    
        public static void main(String[] args) throws InterruptedException {
            int times = 10;
            Exchanger<String> integerExchanger = new Exchanger<>();
            semaphore.acquire();
            new Thread(new Foo(times, integerExchanger)).start();
            new Thread(new Bar(times, integerExchanger)).start();
            try {
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
            }
            System.out.println("##");
        }
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，155人围观）

还没有评论，来说两句吧...

相关阅读

相关 LeetCode 多线程 1115. 交替打印FooBar

[1115. 交替打印FooBar][1115. _FooBar] Ideas 交替锁的设计，两把锁，foo执行的时候把foo lock acquire，print完了

╰+攻爆jí腚メ/ 2023年01月23日 12:57/ 0 赞/ 168 阅读

相关线程交替打印

文章目录 synchronized实现 volatile实现 lock实现 lock+condition实现 Unsafe加锁抢占式实现,支

蔚落/ 2022年11月29日 12:44/ 0 赞/ 175 阅读

相关两个线程交替打印1-100

/ 类描述:两个线程交替打印 @author ：大树 @version 1.0 @date 2021/6/28 18:3

秒速五厘米/ 2022年10月10日 13:56/ 0 赞/ 195 阅读

相关线程理解：三个线程交替顺序打印ABC

一、题目描述建立三个线程A、B、C，A线程打印10次字母A，B线程打印10次字母B,C线程打印10次字母C，但是要求三个线程同时运行，并且实现交替打印，即按照ABCAB

比眉伴天荒/ 2022年10月10日 12:48/ 0 赞/ 196 阅读

相关两个线程交替打印1-10

AtomicInteger num = new AtomicInteger(1); Object lock = new Object();

向右看齐/ 2022年09月15日 15:56/ 0 赞/ 323 阅读

相关多线程-交替打印FooBar(Exchanger+Semaphore)

package com.ctl; import java.util.concurrent.Exchanger; import java.uti

待我称王封你为后i/ 2022年09月13日 13:21/ 0 赞/ 156 阅读

相关多线程交替打印ABC的多种实现方法

一、题目描述建立三个线程A、B、C，A线程打印10次字母A，B线程打印10次字母B,C线程打印10次字母C，但是要求三个线程同时运行，并且实现交替打印，即按照ABCAB

心已赠人/ 2022年06月10日 11:06/ 0 赞/ 195 阅读

相关多线程交替打印ABC的多种实现方法

一、题目描述建立三个线程A、B、C，A线程打印10次字母A，B线程打印10次字母B,C线程打印10次字母C，但是要求三个线程同时运行，并且实现交替打印，即按照ABCAB

ゝ一纸荒年。/ 2022年06月05日 03:18/ 0 赞/ 183 阅读

相关两个线程循环交替打印

不加锁，while+boolean变量死循环 public class Solution { volatile static boolean open

约定不等于承诺〃/ 2022年05月15日 12:22/ 0 赞/ 227 阅读

相关【手撕代码】多个线程交替打印

目录：方法一：锁实现【推荐】方法二：信号量 semaphore 实现【推荐】方法三：wait / notify 实现方法四：使用 Lock / Cond

桃扇骨/ 2022年02月16日 00:39/ 0 赞/ 208 阅读