CloudNativeEra
  • Introduction
  • 名词解释
  • Computer Science
    • Computer Organization
      • CPU
      • 二进制、电路、加法器、乘法器
      • 编译、链接、装载
      • 存储器
      • IO
    • Operating System
      • 操作系统基础知识
      • 系统初始化
      • 进程管理
      • Everything about Memory
      • 文件系统
      • 并行编程
      • Linux
        • CPU
        • IO 多路复用
        • DMA IO and Linux Zero Copy
    • Computer Network
      • 网络相关命令
      • 评估系统的网络性能
      • 网络抓包
      • Linux 最多支撑的 TCP 连接
      • 网络虚拟化
      • DHCP 工作原理
    • Data Structure and Algorithm
      • 题目列表
      • Summarize
        • 方法总结
        • 二分思想
        • 树的演化
        • 算法思想总结
      • Data Structure
        • Data Struct - Array
        • Tree
        • Heap
        • Hash
        • 字符串
      • Algorithm
        • Sorting Algorithm
        • 查找
        • 贪心算法
        • 动态规划
        • 位运算
      • Practice Topics
        • Data Struct in SDK
        • Topic - Tree
        • Topic - Graph
        • Topic - 滑动窗口
        • 剑指 Offer 题解
    • 并发编程
      • 并发模式
      • 并发模型
  • 系统设计
    • 软件设计
      • 软件架构
      • 编程范式
      • 系统设计题
      • 设计原则
      • 计算机程序的构造和解释 SICP
    • 领域驱动设计
      • 应用:在线请假考勤管理
      • 应用: library
    • 微服务与云原生
      • Designing and deploying microservices
      • 容器技术
      • Docker
      • Etcd
      • Kubernetes
        • Kubernetes - Mapping External Services
      • Istio
      • 监控
    • 分布式系统
      • 分布式理论
      • 分布式事务
    • 后端存储设计
      • 缓存设计
      • 数据库架构设计
    • CI/CD
    • 设计最佳实践
    • 测试
    • 安全
    • 综合
      • 开发实践
      • 分布式锁
      • 分布式计数服务
      • 弹幕系统设计
      • 消息队列设计
      • 分布式ID生成算法
      • 限流设计
      • 网关设计
      • 通用的幂等设计
      • 分布式任务调度
        • Timer
        • ScheduledExecutorService
        • Spring Task
        • Quartz
      • 交易系统
      • 权限设计
  • 编程语言
    • 编程语言
    • C & C++
    • Java
      • JVM
        • JVM Bytecode
      • Java 核心技术
      • Java 8 新特性
      • Java 集合框架
      • Java NIO
      • 并发编程
        • 线程生命周期与线程中断
        • 三个线程交替打印
        • 两个线程交替打印奇偶
        • 优雅终止线程
        • 等待通知机制
        • 万能钥匙:管程
        • 限流器
        • 无锁方案 CAS
    • Java 源码阅读
      • Unsafe
      • 异步计算 Future
      • Java Queue
      • CoalescingRingBuffer 分析
      • Java Collections
        • PriorityQueue 分析
        • HashMap 分析
        • TreeMap
    • Golang
    • Python
  • 框架/组件/类库
    • Guava
      • Guava Cache
      • Guava EventBus
    • RxJava
    • Apache MINA
    • Netty
      • 网络 IO 模型
      • Netty 生产问题
    • Apache Tomcat
    • MyBatis
    • 限流框架
    • Spring Framework
      • Spring Core
      • Spring 事务管理
    • Spring Boot
    • Spring Cloud
      • Feign & OpenFeign
      • Ribbon
      • Eurake
      • Spring Cloud Config
    • FixJ
    • Metrics
    • Vert.x
  • 中间件
    • Redis
      • Redis 基础
        • Redis 数据结构设计与实现
        • Redis 高性能网络模型
      • Redis checklist
      • 应用案例 - Redis 数据结构
      • 应用案例 - Redis 缓存应用
      • 应用案例 - Redis 集群
      • Redis 客户端
      • Redis 生产案例
        • [译] 在 Redis 中存储数亿个简单键值对
    • MySQL
      • MySQL 基础
      • MySQL Index
      • MySQL Transaction
      • MySQL 优化
      • MySQL 内核
      • MySQL Command
      • MySQL Checklist
      • MySQL Analysis Tool
      • 实现 MySQL
    • State Machine
    • 数据库连接池
    • MQ
      • 高性能内存队列 Disruptor
      • Kafka
      • Pulsar
      • RocketMQ
        • Broker 的设计与实现
      • NSQ
  • 实际案例
    • 线上 Case
      • Request Aborted
      • MySQL - Specified key was too long
      • Java 应用 CPU 100% 排查优化
      • 频繁 GC 导致的 Java 服务不响应
      • 导出优化
  • 大数据
    • 流计算
    • Flink
  • 其他
    • 工具
    • 读书
      • 设计数据密集型应用
      • 实现领域驱动设计
      • 精通比特币
      • 提问的智慧
    • 论文
    • 工程博客
    • 阅读源码
    • 面试
      • 如何在最短的时间里对对方有个全面的了解
    • 分享
    • 软技能
    • Todo
  • Blog
    • #算法
      • 查找
      • 位运算
      • 树
    • #架构
      • 1- 通信
    • Design & Dev & Opt
      • High Performance Data structure Design
  • Tiny Project
    • A Simple WeChat-like Instant Messaging Platform
由 GitBook 提供支持
在本页
  • 经典问题
  • 用两个线程交替打印奇数和偶数问题

这有帮助吗?

  1. 编程语言
  2. Java
  3. 并发编程

两个线程交替打印奇偶

经典问题

用两个线程交替打印奇数和偶数问题

问题描述: 有两个线程分别输出奇数和偶数,编写程序使得输出顺序是1, 2, 3, 4, 5, 6, 7, 8, 9, 一直到 100

这是一道笔试题,经常出现,能非常好的考察对并发编程的掌握程度,当然实现方式也是多样的。

思路1 用 synchronized 以及等待通知机制解决

分析如下:

  1. 需要启动两个线程A和B

  2. 共享资源是要打印的数字

  3. 线程A打印奇数,线程B打印偶数,线程A打印完之后通知线程B并等待线程B打印完

  4. 线程A或者B能够收到对方的通知,并继续打印自己的数字

// 互斥资源:要打印的数字
// 互斥锁:共享一把锁即可,如 Object lock = new Object();
// 线程要求的条件:两个线程交替执行
// 何时等待:打印完自己的数字等待对方打印
// 何时通知:打印安自己的数字通知对方打印
public class PrintEvenOdd {
    private static volatile int number = 1;
    private static int MAX = 100;

    public static void main(String[] args) {
        // 互斥锁
        Object lock = new Object();

        Runnable runnable = () -> {
            synchronized (lock) {
                while (number <= MAX) {
                    System.out.println(number++);
                    lock.notifyAll();
                    try {
                        lock.wait();
                    } catch (InterruptedException e) {}
                }

                lock.notifyAll();
            }
        };

        // 启动奇数线程
        new Thread(runnable, "奇数线程").start();

        // 启动偶数线程
        new Thread(runnable, "偶数线程").start();
    }
}

思路2 利用 synchronized 或者 Lock 接口结合判断奇偶的方式

思路1 利用了等待-通知机制,是我认为的最优秀的解决方法了。判断奇偶的思路更容易理解。

public class PrintEvenOdd {

    public static void main(String[] args) {
        Lock lock = new ReentrantLock();

        // 奇数线程
        new Thread(new PThread(lock, 0)).start();

        // 偶数线程
        new Thread(new PThread(lock, 1)).start();
    }
}

class PThread implements Runnable {
    private Lock lock;
    private int flag;

    private PThread() {
    }

    public PThread(Lock lock, int flag) {
        this.lock = lock;
        this.flag = flag;
    }

    // 共享资源
    private static int number = 0;
    private static int MAX = 100;

    @Override
    public void run() {
        while (true) {
            lock.lock();
            if (number > MAX) {
                lock.unlock();
                return;
            }

            // 判断奇偶
            if (number % 2 == flag) {
                System.out.println(number);
                number++;
            }

            lock.unlock();
        }
    }
}

思路3 可以利用 Lock 和 Condition 交替打印

这种方式本质上还是等待-通知机制,也非常棒。

public class PrintEvenOdd3 {
    private static volatile int number = 1;
    private static int MAX = 100;

    public static void main(String[] args) {
        Lock lock = new ReentrantLock();
        // 奇数 Condition
        Condition oddCond = lock.newCondition();
        // 偶数 Condition
        Condition evenCond = lock.newCondition();

        Runnable runnable = () -> {
            while (true) {
                lock.lock();

                if (number > MAX) {
                    oddCond.signalAll();
                    evenCond.signalAll();
                    lock.unlock();
                    return;
                }

                // odd
                if (number % 2 == 1) {
                    System.out.println(Thread.currentThread().getName() + number);
                    number++;
                    // notify 偶数 Condition
                    evenCond.notifyAll();
                    try {
                        oddCond.await();
                    } catch (Exception e) {}
                } else {  // even
                    System.out.println(Thread.currentThread().getName() + number);
                    number++;
                    // notify 奇数 Condtion
                    oddCond.notifyAll();
                    try {
                        evenCond.await();
                    } catch (Exception e) {}
                }

                lock.unlock();
            }
        };

        // start odd thread
        new Thread(runnable, "odd").start();
        // start even thread
        new Thread(runnable, "even").start();
    }
}
上一页三个线程交替打印下一页优雅终止线程

最后更新于5年前

这有帮助吗?