读Java并发编程实践中,向已有线程安全类添加功能--客户端加锁实现示例

时间:2022-03-29 02:32:37

在Java并发编程实践中4.4中提到向客户端加锁的方法。此为验证示例,写的不好,但可以看出结果来。

package com.blackbread.test;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; public class GoodListHelper<E> {
public List<E> list = Collections.synchronizedList(new ArrayList<E>()); public boolean putIfAbsent(E x) throws InterruptedException {
synchronized (list) {
boolean absent = !list.contains(x);
if (absent) {
if (list.contains(x))
System.out.println(list.contains(x));
list.add(x);
}
return absent;
}
} public class PrintA extends Thread {
private GoodListHelper<String> goodListHelper;
private String value; public PrintA(GoodListHelper<String> goodListHelper, String value) {
this.goodListHelper = goodListHelper;
this.value = value;
} @Override
public void run() {
try {
goodListHelper.putIfAbsent(value);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
} public class PrintB extends Thread {
private GoodListHelper<String> goodListHelper;
private String value; public PrintB(GoodListHelper<String> goodListHelper, String value) {
this.goodListHelper = goodListHelper;
this.value = value;
} @Override
public void run() {
goodListHelper.list.add(value);
}
} public static void main(String[] args) throws InterruptedException {
final GoodListHelper<String> goodListHelper = new GoodListHelper<String>();
new Thread(new Runnable() {
@Override
public void run() {
ExecutorService executor = Executors.newFixedThreadPool(50);
for (int i = 0; i < 1000; i++) {
Thread t = goodListHelper.new PrintA(goodListHelper,
String.valueOf(i));
executor.execute(t);
}
executor.shutdown();
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
ExecutorService executor = Executors.newFixedThreadPool(50);
for (int i = 0; i < 1000; i++) {
Thread t = goodListHelper.new PrintB(goodListHelper,
String.valueOf(i));
executor.execute(t);
}
executor.shutdown();
}
}).start();
}
}

读Java并发编程实践中,向已有线程安全类添加功能--客户端加锁实现示例的更多相关文章

  1. Java并发编程实践

    最近阅读了<Java并发编程实践>这本书,总结了一下几个相关的知识点. 线程安全 当多个线程访问某个类时,不管运行时环境采用何种调度方式或者这些线程将如何交替执行,并且在主调代码中不需要任 ...

  2. &lbrack;Java 并发&rsqb; Java并发编程实践 思维导图 - 第一章 简单介绍

    阅读<Java并发编程实践>一书后整理的思维导图.

  3. &lbrack;Java 并发&rsqb; Java并发编程实践 思维导图 - 第二章 线程安全性

    依据<Java并发编程实践>一书整理的思维导图.

  4. &lbrack;Java 并发&rsqb; Java并发编程实践 思维导图 - 第四章 对象的组合

    依据<Java并发编程实践>一书整理的思维导图. 第一部分: 第二部分:

  5. java并发编程实践笔记

    文章转自:http://kenwublog.com/java-concurrency-in-practise-note 1, 保证线程安全的三种方法 :a, 不要跨线程访问共享变量b, 使共享变量是 ...

  6. 笔记:java并发编程实践1

    Java 5.0 adds ConcurrentHashMap, a replacement for synchronized hash-based Map implementations, and ...

  7. Java并发编程&lpar;多线程&rpar;中的相关概念

    众所周知,在Java的知识体系中,并发编程是非常重要的一环,也是面试中必问的题,一个好的Java程序员是必须对并发编程这块有所了解的. 并发必须知道的概念 在深入学习并发编程之前,我们需要了解几个基本 ...

  8. Java 并发编程实践基础 读书笔记: 第三章 使用 JDK 并发包构建程序

    一,JDK并发包实际上就是指java.util.concurrent包里面的那些类和接口等 主要分为以下几类: 1,原子量:2,并发集合:3,同步器:4,可重入锁:5,线程池 二,原子量 原子变量主要 ...

  9. Java并发编程实践读书笔记(2)多线程基础组件

    同步容器 同步容器是指那些对所有的操作都进行加锁(synchronize)的容器.比如Vector.HashTable和Collections.synchronizedXXX返回系列对象: 可以看到, ...

随机推荐

  1. 初识JavaScript

    JavaScript ECMA-262: 变量,函数,对象,数据类型....唯独没有输入和输出. Javascript:包含 ECMA-262,核心 BOM 浏览器对象模型, DOM 文档对象模型 什 ...

  2. 适合WebApi的简单的C&num;状态机实现

    目标 采用了Restful WebApi的架构,再把业务逻辑状态转移放到后端就有点违背初衷了.实际上只要后端Api的权限设置的好,把状态转移放到前端也未尝不可.我考虑的结果是,一般如果变更这个状态本身 ...

  3. jquery1&colon;

    在jquery中:1.window.onload: --->$();所以一般jquery用如下开头: $(function(){ })2.获取元素:$('#div'):获取id为div的元素$( ...

  4. C&num;中 &plus;&equals; &lpar;s&comma; e&rpar; &equals;&gt&semi; 这些字符什么意思

    public MainWindow(){InitializeComponent();this.Loaded += (s, e) => DiscoverKinectSensor();this.Un ...

  5. Codeforces Round &num;336 &lpar;Div&period; 2&rpar; D&period; Zuma 记忆化搜索

    D. Zuma 题目连接: http://www.codeforces.com/contest/608/problem/D Description Genos recently installed t ...

  6. &lbrack;转载&rsqb;Windows 7 IIS &lpar;HTTP Error 500&period;21 - Internal Server Error&rpar;解决

    今天在测试网站的时候,在浏览器中输入http://localhost/时,发生如下错误: HTTP Error 500.21 - Internal Server Error Handler &quot ...

  7. javascript常用方法整理--数组篇

    1. arrayObject.slice(start,end) 从已有的数组中返回选定的元素 参数 描述 start 必需.规定从何处开始选取.如果是负数,那么它规定从数组尾部开始算起的位置.也就是说 ...

  8. 用MySQL创建数据库和数据库表

    1.使用SHOW语句找出在服务器上当前存在什么数据库: mysql> SHOW DATABASES; +----------+ | Database | +----------+ | mysql ...

  9. 合理设计C代码 函数笔记

    本文首先用判断一个数字是否为素数使用For循环实现做例子,之后用函数完成多个功能. 什么是素数? 素数又成质数,不包含1和0.通俗的去说就是它除了能表示为它自己和1的乘积以外,不能表示为任何其它两个整 ...

  10. node的cookie-parser和express-session

    let express = require('express'); let cookieParser = require('cookie-parser'); let expressSession = ...