Java多线程共享数据

    xiaoxiao2021-03-26  31

    多线程共享数据的方式:

     

    如果多个线程执行同一个操作,则他们可以共享一个Runnable对象,如售票系统

    如果多个线程执行不同的操作,如银行的存取款,针对不同的操作创建不同的Runnable对象

     

    有两种方法来解决此类问题:

    创建ShareData类,封装要操作的数据对象,并且用synchronized序列化对该数据对象的“互斥”操作方法,将该对象的不同的操作方法传递给不同的Thread的Runnuble对象,本例创建了200个Thread对象,这200个Thread对象分别对数据进行并行处理

    创建Account类,封装要操作的数据对象,并且用synchronized序列化对该数据对象的“互斥”操作方法,针对不同的操作方法创建相对应的Runnable类(将该数据对象传递给该Runnalbe类)

    package multiThreadDataShare; public class MultiThreadShareData0 { public static void main(String[] args){ new MultiThreadShareData0().run(); } public void run(){ Ticket t = new Ticket(); new Thread(t).start(); new Thread(t).start(); new Thread(t).start(); new Thread(t).start(); } class Ticket implements Runnable{ private int ticket = 10; @Override //记得要资源公共,要在run方法之前加上synchronized关键字,要不然会出现抢资源的情况 public synchronized void run() { System.out.println(Thread.currentThread().getName()+"当前票数为:"+ticket); ticket--; } } }package multiThreadDataShare; /** * 多个线程共享数据的方式,每个线程执行的代码不同,使用不同的Runnable对象 * 设计四个线程,其中两个线程每次对j增加1,另外两个线程对j减少1 * 循环100次 * @author asusd * 银行存取款,存取款各占一个线程 */ public class MultiThreadShareData1 { public static void main(String[] args){ new MultiThreadShareData1().run(); } public void run(){ ShareData data1 = new ShareData(); for(int i=0;i<100;i++){ new Thread(new Runnable(){ public void run(){ data1.increment(); } }).start(); new Thread(new Runnable(){ public void run(){ data1.decrement(); } }).start(); } } /** * 封装共享数据 */ class ShareData{ private int j=0; /** * 每次对j增加1 */ public synchronized void increment(){ j++; System.out.println("线程"+Thread.currentThread().getName()+"j++="+j); } /* * 每次对j减少1 */ public synchronized void decrement(){ j--; System.out.println("线程"+Thread.currentThread().getName()+"j--="+j); } } } package multiThreadDataShare; public class Account { private int money=0; private String name; public Account(String name){ this.name = name; } public synchronized void getMoney(int money){ while(this.money

     

    转载请注明原文地址: https://ju.6miu.com/read-664388.html

    最新回复(0)