java多线程并发中使用Lockers类将多线程共享资源锁定

复制代码 代码如下:

package com.yao;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

/**
 * Lockers
 * 在多线程编程里面一个重要的概念是锁定,如果一个资源是多个线程共享的,为了保证数据的完整性,
 * 在进行事务性操作时需要将共享资源锁定,这样可以保证在做事务性操作时只有一个线程能对资源进行操作,
 * 从而保证数据的完整性。在5.0以前,锁定的功能是由Synchronized关键字来实现的。
 */
public class Lockers {

/**
  * 测试Lock的使用。在方法中使用Lock,可以避免使用Synchronized关键字。
  */
 public static class LockTest {

Lock lock = new ReentrantLock();// 锁
  double value = 0d; // 值
  int addtimes = 0;

/**
   * 增加value的值,该方法的操作分为2步,而且相互依赖,必须实现在一个事务中
   * 所以该方法必须同步,以前的做法是在方法声明中使用Synchronized关键字。
   */
  public void addValue(double v) {
   lock.lock();// 取得锁
   System.out.println("LockTest to addValue: " + v + "   "
     + System.currentTimeMillis());
   try {
    Thread.sleep(1000);
   } catch (InterruptedException e) {
   }
   this.value += v;
   this.addtimes++;
   lock.unlock();// 释放锁
  }

public double getValue() {
   return this.value;
  }
 }
 public static void testLockTest() throws Exception{
  final LockTest lockTest = new LockTest();
  // 新建任务1,调用lockTest的addValue方法
  Runnable task1 = new Runnable(){
   public void run(){
    lockTest.addValue(55.55);
   }
  };
  // 新建任务2,调用lockTest的getValue方法
  Runnable task2 = new Runnable(){
   public void run(){
    System.out.println("value: " + lockTest.getValue());
   }
  };
  // 新建任务执行服务
  ExecutorService cachedService = Executors.newCachedThreadPool();
  Future future = null;
  // 同时执行任务1三次,由于addValue方法使用了锁机制,所以,实质上会顺序执行
  for (int i=0; i<3; i++){
   future = cachedService.submit(task1);
  }
  // 等待最后一个任务1被执行完
  future.get();
  // 再执行任务2,输出结果
  future = cachedService.submit(task2);
  // 等待任务2执行完后,关闭任务执行服务
  future.get();
  cachedService.shutdownNow();
 }

/**
  * ReadWriteLock内置两个Lock,一个是读的Lock,一个是写的Lock。
  * 多个线程可同时得到读的Lock,但只有一个线程能得到写的Lock,
  * 而且写的Lock被锁定后,任何线程都不能得到Lock。ReadWriteLock提供的方法有:
  * readLock(): 返回一个读的lock
  * writeLock(): 返回一个写的lock, 此lock是排他的。
  * ReadWriteLockTest很适合处理类似文件的读写操作。
  * 读的时候可以同时读,但不能写;写的时候既不能同时写也不能读。
  */
 public static class ReadWriteLockTest{
  // 锁
  ReadWriteLock lock = new ReentrantReadWriteLock();
  // 值
  double value = 0d;
  int addtimes = 0;

/**
   * 增加value的值,不允许多个线程同时进入该方法
   */
  public void addValue(double v) {
   // 得到writeLock并锁定
   Lock writeLock = lock.writeLock();
   writeLock.lock();
   System.out.println("ReadWriteLockTest to addValue: " + v + "   "
     + System.currentTimeMillis());
   try {
    Thread.sleep(1000);
   } catch (InterruptedException e) {
   }
   try {
    // 做写的工作
    this.value += v;
    this.addtimes++;
   } finally {
    // 释放writeLock锁
    writeLock.unlock();
   }
  }
  /**
   * 获得信息。当有线程在调用addValue方法时,getInfo得到的信息可能是不正确的。
   * 所以,也必须保证该方法在被调用时,没有方法在调用addValue方法。
   */
  public String getInfo() {
   // 得到readLock并锁定
   Lock readLock = lock.readLock();
   readLock.lock();
   System.out.println("ReadWriteLockTest to getInfo   "
     + System.currentTimeMillis());
   try {
    Thread.sleep(1000);
   } catch (InterruptedException e) {
   }
   try {
    // 做读的工作
    return this.value + " : " + this.addtimes;
   } finally {
    // 释放readLock
    readLock.unlock();
   }
  }
 }

public static void testReadWriteLockTest() throws Exception{
  final ReadWriteLockTest readWriteLockTest = new ReadWriteLockTest();
  // 新建任务1,调用lockTest的addValue方法
  Runnable task_1 = new Runnable(){
   public void run(){
    readWriteLockTest.addValue(55.55);
   }
  };
  // 新建任务2,调用lockTest的getValue方法
  Runnable task_2 = new Runnable(){
   public void run(){
    System.out.println("info: " + readWriteLockTest.getInfo());
   }
  };
  // 新建任务执行服务
  ExecutorService cachedService_1 = Executors.newCachedThreadPool();
  Future future_1 = null;
  // 同时执行5个任务,其中前2个任务是task_1,后两个任务是task_2
  for (int i=0; i<2; i++){
   future_1 = cachedService_1.submit(task_1);
  }
  for (int i=0; i<2; i++){
   future_1 = cachedService_1.submit(task_2);
  }
  // 最后一个任务是task_1
  future_1 = cachedService_1.submit(task_1);
  // 这5个任务的执行顺序应该是:
  // 第一个task_1先执行,第二个task_1再执行;这是因为不能同时写,所以必须等。
  // 然后2个task_2同时执行;这是因为在写的时候,就不能读,所以都等待写结束,
  // 又因为可以同时读,所以它们同时执行
  // 最后一个task_1再执行。这是因为在读的时候,也不能写,所以必须等待读结束后,才能写。

// 等待最后一个task_2被执行完
  future_1.get();
  cachedService_1.shutdownNow();
 }

public static void main(String[] args) throws Exception{
  Lockers.testLockTest();
  System.out.println("---------------------");
  Lockers.testReadWriteLockTest();
 }
}

时间: 2014-01-13

Java使用wait() notify()方法操作共享资源详解

Java多个线程共享资源: 1)wait().notify()和notifyAll()方法是本地方法,并且为final方法,无法被重写. 2)调用某个对象的wait()方法能让当前线程阻塞,并且当前线程必须拥有此对象的monitor(即锁,或者叫管程) 3)调用某个对象的notify()方法能够唤醒一个正在等待这个对象的monitor的线程,如果有多个线程都在等待这个对象的monitor,则只能唤醒其中一个线程: 4)调用notifyAll()方法能够唤醒所有正在等待这个对象的monitor的线

Java多线程编程之ThreadLocal线程范围内的共享变量

模拟ThreadLocal类实现:线程范围内的共享变量,每个线程只能访问他自己的,不能访问别的线程. package com.ljq.test.thread; import java.util.HashMap; import java.util.Map; import java.util.Random; /** * 线程范围内的共享变量 * * 三个模块共享数据,主线程模块和AB模块 * * @author Administrator * */ public class ThreadScopeS

Java中tomcat memecached session 共享同步问题的解决办法

事件缘由:一个主项目"图说美物",另外一个子功能是品牌商的入驻功能,是跟主项目分开的项目,为了共享登录的用户信息,而实现session共享,俩个tomcat,一个tomcat6,一个tomcat7 web项目windows系统下实现session的共享 第一个步: 在俩个tomcat的context.xml这个文件中配置如下代码: <Manager className="de.javakaffee.web.msm.MemcachedBackupSessionManage

Java读写Windows共享文件夹的方法实例

项目常常需要有访问共享文件夹的需求,例如共享文件夹存储照片.文件等.那么如何使用Java读写Windows共享文件夹呢? Java可以使用JCIFS框架对Windows共享文件夹进行读写,就这个框架可以让我们像访问本地文件夹一下访问远程文件夹. JCIFS的网址: http://jcifs.samba.org/ JCIFS是使用纯Java开发的一个开源框架,通过smb协议访问远程文件夹.该框架同时支持Windows共享文件夹和Linux共享文件夹,不过,Linux共享文件夹需要安装Samba服务

Java多线程编程之访问共享对象和数据的方法

多个线程访问共享对象和数据的方式有两种情况: 1.每个线程执行的代码相同,例如,卖票:多个窗口同时卖这100张票,这100张票需要多个线程共享. 2.每个线程执行的代码不同,例如:设计四个线程,其中两个线程每次对j增加1,另外两个线程每次对j减少1. a.如果每个线程执行的代码相同,可以使用同一个Runnable对象,这个对象中有共享数据.卖票就可以这样做,每个窗口都在做卖票任务,卖的票都是同一个数据(点击查看具体案例). b.如果每个线程执行的代码不同,就需要使用不同的Runnable对象,有

Java设计模式之共享模式/享元模式(Flyweight模式)介绍

Flyweight定义:避免大量拥有相同内容的小类的开销(如耗费内存),使大家共享一个类(元类). 为什么使用共享模式/享元模式 面向对象语言的原则就是一切都是对象,但是如果真正使用起来,有时对象数可能显得很庞大,比如,字处理软件,如果以每个文字都作为一个对象,几千个字,对象数就是几千,无疑耗费内存,那么我们还是要"求同存异",找出这些对象群的共同点,设计一个元类,封装可以被共享的类,另外,还有一些特性是取决于应用(context),是不可共享的,这也Flyweight中两个重要概念内

java实现屏幕共享功能实例分析

本文实例讲述了java实现屏幕共享功能的方法.分享给大家供大家参考.具体分析如下: 最近在做软件软件工程的课程设计,做一个用于实验室的屏幕监控系统,参考各种前人代码,最后领悟之后要转换自己的代码,初学者都是这样模仿过来的. 说到屏幕监控系统,有教师端和学生端,教师端就是Server端,学生端就做Client端.系统里比较有趣的一个地方应该算是屏幕广播与屏幕监控吧,其余什么点名签到,锁屏,定时关机的,就相对来说简单点. 屏幕广播,在功能实现上面,说白了,就是教师端的机器不断截取屏幕信息,以图片的形

Java线程重复执行以及操作共享变量的代码示例

1.题目:主线程执行10次,子线程执行10次,此过程重复50次 代码: package com.Thread.test; /* * function:主线程执行10次,子线程执行10次, * 此过程重复50次 */ public class ThreadProblem { public ThreadProblem() { final Business bus = new Business(); new Thread(new Runnable() { public void run() { for

Java 存储模型和共享对象详解

Java 存储模型和共享对象详解 很多程序员对一个共享变量初始化要注意可见性和安全发布(安全地构建一个对象,并其他线程能正确访问)等问题不是很理解,认为Java是一个屏蔽内存细节的平台,连对象回收都不需要关心,因此谈到可见性和安全发布大多不知所云.其实关键在于对Java存储模型,可见性和安全发布的问题是起源于Java的存储结构. Java存储模型原理 有很多书和文章都讲解过Java存储模型,其中一个图很清晰地说明了其存储结构: 由上图可知, jvm系统中存在一个主内存(Main Memory或J

java通过共享变量结束run停止线程的方法示例

stop()方法已经被弃用,原因是不太安全.API文档中给出了具体的详细解释.通过interrupted()方法打断线程.不推荐.通过共享变量结束run()方法,进而停止线程.如实例 复制代码 代码如下: public class ThreadInterrupt {    public static void main(String []args){        Runner run = new Runner();        run.start();        try {       

Java通过在主循环中判断Boolean来停止线程的方法示例

本文实例讲述了Java通过在主循环中判断Boolean来停止线程的方法.分享给大家供大家参考,具体如下: package Threads; /** * Created by Frank */ public class StopBoolean extends Thread { // 确保变化对其它线程可见(主要是主线程要可见) protected volatile boolean done = false; public void run() { while (!done) { System.ou

java多线程之停止线程的方法实例代码详解

和线程停止相关的三个方法 /* 中断线程.如果线程被wait(),join(),sleep()等方法阻塞,调用interrupt()会清除线程中断状态,并收到InterruptedException异常.另外interrupt();对于isAlive()返回false的线程不起作用. */ public void interrupt(); /* 静态方法,判断线程中断状态,并且会清除线程的中断状态.所以连续多次调用该方法,第二次之后必定返回false.另外,isAlive()用于判断线程是否处于

Java使用Thread和Runnable的线程实现方法比较

本文实例讲述了Java使用Thread和Runnable的线程实现方法.分享给大家供大家参考,具体如下: 一 使用Thread实现多线程模拟铁路售票系统 1 代码 public class ThreadDemo { public static void main( String[] args ) { TestThread newTh = new TestThread( ); // 一个线程对象只能启动一次 newTh.start( ); newTh.start( ); newTh.start(

C#停止线程的方法

本文实例讲述了C#停止线程的方法.分享给大家供大家参考.具体实现方法如下: using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; namespace WinFormApp { publi

java中接口(interface)及使用方法示例

1.接口:一种把类抽象的更彻底,接口里只能包含抽象方法的"特殊类".接口不关心类的内部状态数据,定义的是一批类所遵守的规范.(它只规定这批类里必须提供某些方法,提供这些方法就可以满足实际要求). 在JAVA编程语言中是一个抽象类型,是抽象方法的集合,接口通常以interface来声明.一个类通过继承接口的方式,从而来继承接口的抽象方法. 接口并不是类,编写接口的方式和类很相似,但是它们属于不同的概念.类描述对象的属性和方法.接口则包含类要实现的方法. 除非实现接口的类是抽象类,否则该类

Java 创建并应用PPT幻灯片母版的方法示例

前言 在PowerPoint文档中,幻灯片母版可供用户设置幻灯片的样式,比如标题文字.背景.属性等.预先设定好的幻灯片母版可用于所有幻灯片,此外,也可创建多个幻灯片母版分别应用到幻灯片中.本文将介绍如何创建并应用单个或多个幻灯片母版. 环境构建 文中演示代码用到的工具是Free Spire.Presentation for Java,可通过官网下载获取.解压后将位于lib文件夹下的Spire.Presentation.jar导入Java程序.此外,还可通过maven仓库安装导入. Java代码示

面试题:Java中如何停止线程的方法

如何停止线程是Java并发面试中的常见问题,本篇文章将从答题思路到答题细节给出一些参考. 答题思路: 停止线程的正确方式是使用中断 想停止线程需要停止方,被停止方,被停止方的子方法相互配合 扩展到常见的错误停止线程方法:已被废弃的stop/suspend,无法唤醒阻塞线程的volatile 1. 正确方式是中断 其实从逻辑上也很好理解的,一个线程正在运行,如何让他停止? A. 从外部直接调用该线程的stop方法,直接把线程停下来. B. 从外部通过中断通知线程停止,然后切换到被停止的线程,该线程

Java使用正则表达式删除所有HTML标签的方法示例

本文实例讲述了Java使用正则表达式删除所有HTML标签的方法.分享给大家供大家参考,具体如下: package com.xz.cxzy.utils; import java.util.regex.Matcher; import java.util.regex.Pattern; public class HtmlUtil { private static final String regEx_script = "<script[^>]*?>[\\s\\S]*?<\\/sc

Java正则判断日期格式是否正确的方法示例

本文实例讲述了Java正则判断日期格式是否正确的方法.分享给大家供大家参考,具体如下: 1.Java中用正则表达式判断日期格式是否正确 DateType.java: /** * @Title:DateType.java * @Package:com.you.dao * @Description: * @Author: 游海东 * @Version V1.2.3 */ package com.you.dao; import java.util.regex.Matcher; import java.