Java笔记第九弹

2022-08-01 21:36:50 阅读：190 来源： 互联网

标签：tickets Java Thread void 笔记 start private new 第九

升级版：

数据安全问题的解决

1、同步代码块

(弊端：降低了运行效率)

格式：(锁--同一把锁)

synchronized(任意对象){
    多条语句操作共享数据的代码
}

//sellTicket.java
private int tickets=100;
private Object obj=new Object();//设置同一把锁
public void run(){
    while(true){//死循环
    if(tickets>0){//实现卖票
        //通过sleep()方法模拟出票时间
        synchronized(obj){//new Object()表示任意对象
        try{
        Thread.sleep(100);
        }catch(InterruptedException e){
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()+"正在出售第"+tickets+"张票");
        tickets--;
    }
    }
    }
}

//sellTicketDemo.java
sellTicket t1=new sellTicket();

Thread d1=new Thread(t1,"窗口1");
Thread d2=new Thread(t2,"窗口2");
Thread d3=new Thread(t3,"窗口3");

d1.start();
d2.start();
d3.start();

同步方法--锁对象this

//sellTicket.java
public void run(){
    private int tickets=100;
    private Object obj=new Object();
    private int x=0;
    while(true){//死循环
        if(x%2==0){
     if(tickets>0){//实现卖票
        //通过sleep()方法模拟出票时间
        synchronized(obj){//new Object()表示任意对象
        try{
        Thread.sleep(100);
        }catch(InterruptedException e){
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()+"正在出售第"+tickets+"张票");
        tickets--;
    }
    }
        }else{
            synchronized(obj){//new Object()表示任意对象
        try{
        Thread.sleep(100);
        }catch(InterruptedException e){
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()+"正在出售第"+tickets+"张票");
        tickets--;
        }
        }
    }
}

//sellTicketDemo.java
sellTicket t1=new sellTicket();

Thread d1=new Thread(t1,"窗口1");
Thread d2=new Thread(t2,"窗口2");
Thread d3=new Thread(t3,"窗口3");

d1.start();
d2.start();
d3.start();

同步静态方法--锁对象：类名.this

//sellTicket.java
public void run(){
    private static int tickets=100;
    private Object obj=new Object();
    private int x=0;
    while(true){//死循环
        if(x%2==0){
     if(tickets>0){//实现卖票
        //通过sleep()方法模拟出票时间
        synchronized(this){//this对象
        try{
        Thread.sleep(100);
        }catch(InterruptedException e){
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()+"正在出售第"+tickets+"张票");
        tickets--;
    }
    }
    }else{
        sell();
     }
     }
}

private static synchronized void sell(){//方法
    if(tickets>0){//实现卖票
        //通过sleep()方法模拟出票时间
        synchronized(obj){//new Object()表示任意对象
        try{
        Thread.sleep(100);
        }catch(InterruptedException e){
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()+"正在出售第"+tickets+"张票");
        tickets--;
    }
    }
}

//sellTicketDemo.java
sellTicket t1=new sellTicket();

Thread d1=new Thread(t1,"窗口1");
Thread d2=new Thread(t2,"窗口2");
Thread d3=new Thread(t3,"窗口3");

d1.start();
d2.start();
d3.start();

同步静态方法（格式）：

修饰符 static synchronized 返回值类型 方法名(方法参数){}

线程安全的类：

//类中都有synchronized
StringBuffer//线程安全，可变化的字符序列
     Vector//可变化的对象数组
    //对线程安全无要求的话，建议用ArrayList代替Vector
    Hashtable

Lock锁

//锁对象是一个接口
//方法
void lock();//获得锁
void unlock();//释放锁
//实现类
ReentrantLock类
    //构造方法：
    ReentrantLock();

生产者消费者

//为了体现生产者和消费者之间的等待和唤醒，Java提供了几个方法，在Object类中
void wait();//导致当前线程等待，直到另一个线程调用该对象的notify()方法或notifyAll()方法
void notify();//唤醒正在等待对象监视器的单个线程
void notifyAll();//唤醒正在等待对象监视器的全部线程

相关应用：（生产者消费者案例）

//BoxDemo.java
public class BoxDemo{
    public static void main(String[] args){
        //创建奶箱对象
        Box b=new Box();
        //创建生产者对象
        Producer p=new Producer(b);
        //创建消费者对象
        Customer c=new Customer(b);
        //创建两个线程对象
        Thread t1=new Thread(p);
        Thread t2=new Thread(c);
        
        //启动线程
        t1.start();
        t2.start();
        
       }
}
//Box.java
public class Box{
    private int milk;//第x瓶奶
    
    private boolean state=false;//表示奶箱的状态
    
    //定义两个方法，存储和获取牛奶
    public synchronized void put(int milk){
        
        if(state){//表示有牛奶，等待消费
            try{
                wait();
            }catch(InterruptedException e){
                e.printStackTrace();
            }
        }
        //如果没有牛奶，进行生产
        this.milk=milk;
        System.out.println("送奶工将第"+this.milk+"瓶奶放入奶箱");
        //生产完后
        state=true;
        //唤醒线程
        notifyAll();
    }
    
    public synchronized void get(int milk){
        if(!state){//没有牛奶，等待生产
            try{
                wait();
            }catch(InterrupedException e){
                e.printStackTrace();
            }
        }
        //有牛奶，进行消费
        this.milk=milk;
        System.out.println("消费者取走第"+this.milk+"瓶奶");
        //消费完成后，等待生产
        state=false;
        //唤醒线程
        notifyAll();
    }
}
//Producer.java
public class Producer implements Runnable{
    private Box b;
    public Producer(Box b){
        this.b=b;
    }
    public void run(){
        for(int i=1;i<=5;i++){
            b.put(i);
        }
    }
}
//Customer.java
public class Customer implements Runnable{
    private Box b;
    public Customer(Box b){
        this.b=b;
    }
    public void run(){
        while(true){
            b.get();
        }
    }
}

网络编程

网络编程入门

网络编程概述

在网络通信协议下，实现网络互连的不同计算机上运行的程序间可以进行数据交换；

（实现信息共享）

标签：tickets,Java,Thread,void,笔记,start,private,new,第九
来源： https://www.cnblogs.com/liuzijin/p/16541782.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9