w6889037
- 浏览: 29152 次
- 性别:
-
社区版块
- ( 0)
- ( 0)
- ( 1)
最新评论
-
sea000sea：
感谢楼主的总结分享，刚好我在学这块内容！
json-lib.jar拼装json字符串
文章列表
- 博客分类：
- current
package concurrent.arrayblockingqueue;
import java.util.iterator;
import java.util.concurrent.arrayblockingqueue;
import java.util.concurrent.blockingqueue;
import java.util.concurrent.timeunit;
/**
* arrayblockingqueue长度固定大小
* linkedblockingqueue长度大小可以不固定
*
* 插入方法：
* add(e e)：将指定 ...
- 2015-01-25 21:26
- 浏览 519
- 分类:编程语言
- 博客分类：
- current
package concurrent.concurrentskiplistmap;
import java.util.iterator;
import java.util.set;
import java.util.concurrent.concurrentskiplistmap;
/**
* concurrentskiplistmap：有序的并发map
*
*/
public class concurrentskiplistmaptest {
public static void main(string[] args) {
concurrentskipl ...
- 2015-01-25 21:21
- 浏览 538
- 分类:编程语言
- 博客分类：
- current
package concurrent.copyonwritearraylist;
import java.util.arraylist;
import java.util.collection;
import java.util.iterator;
import java.util.concurrent.copyonwritearraylist;
/**
* copyonwritearraylist功能与arraylist类似
* arraylist在对其使用的迭代器遍历期间如果对list中的内容进行修改，会抛异常
* copyonwritearraylist弥补 ...
- 2015-01-25 21:19
- 浏览 307
- 分类:编程语言
- 博客分类：
- current
package concurrent.countdownlatch;
import java.util.concurrent.countdownlatch;
import java.util.concurrent.cyclicbarrier;
import java.util.concurrent.executorservice;
import java.util.concurrent.executors;
/**
* 当调用 countdownlatch的await方法时,所有线程阻塞
* 当countdownlatch不断调用countdown方法使计数器减为0时,所有 ...
- 2015-01-24 21:21
- 浏览 369
- 分类:编程语言
- 博客分类：
- current
package concurrent.cyclicbarrier;
import java.util.concurrent.cyclicbarrier;
import java.util.concurrent.executorservice;
import java.util.concurrent.executors;
/**
* 设置线程路障
* await方法可以阻挡所有线程通过,当到达路障的线程数量为构造方法初始值时,就会放行
*
*/
public class cyclicbarriertest {
public static void main( ...
- 2015-01-24 21:20
- 浏览 401
- 分类:编程语言
- 博客分类：
- current
package concurrent.exchanger;
import java.util.concurrent.exchanger;
import java.util.concurrent.executorservice;
import java.util.concurrent.executors;
/**
* 交换数据
* 当两个线程都到达exchanger.exchange(data)的时候就会交换数据
*/
public class exchangertest {
public static void main(string[] args) {
...
- 2015-01-24 21:19
- 浏览 285
- 分类:编程语言
- 博客分类：
- current
package concurrent.future;
import java.util.concurrent.callable;
import java.util.concurrent.completionservice;
import java.util.concurrent.executorcompletionservice;
import java.util.concurrent.executorservice;
import java.util.concurrent.executors;
import java.util.concurrent.future;
imp ...
- 2015-01-24 21:17
- 浏览 391
- 分类:编程语言
- 博客分类：
- current
package concurrent.lock;
import java.util.hashmap;
import java.util.map;
import java.util.concurrent.locks.readwritelock;
import java.util.concurrent.locks.reentrantreadwritelock;
public class cachedemo {
private map cache = new hashmap();
...
- 2015-01-24 21:15
- 浏览 824
- 分类:编程语言
- 博客分类：
- current
package concurrent.lock;
import java.util.concurrent.executorservice;
import java.util.concurrent.executors;
import java.util.concurrent.semaphore;
/**
* 信号灯
* 只有拿到信号灯的线程才能执行,没拿到信号灯的要等待
*
*/
public class semaphoretest {
public static void main(string[] args) {
executorservice s ...
- 2015-01-23 23:34
- 浏览 294
- 分类:编程语言
- 博客分类：
- current
package concurrent.lock;
import java.util.concurrent.locks.condition;
import java.util.concurrent.locks.lock;
import java.util.concurrent.locks.reentrantlock;
public class conditiontest {
/**
* @param args
*/
public static void main(string[] args) {
final business business ...
- 2015-01-23 23:30
- 浏览 264
- 分类:编程语言
- 博客分类：
- current
package concurrent.lock;
import java.util.random;
import java.util.concurrent.locks.readwritelock;
import java.util.concurrent.locks.reentrantreadwritelock;
public class readwritelocktest {
public static void main(string[] args) {
final queue3 q3 = new queue3();
for(int i=0;i<3;i ...
- 2015-01-23 23:28
- 浏览 707
- 分类:编程语言
- 博客分类：
- current
package concurrent.lock;
import java.util.concurrent.locks.lock;
import java.util.concurrent.locks.reentrantlock;
public class printmsg{
private lock lock=new reentrantlock();
public void print(string name){
while(true){
lock.lock();
try{
for(int i=0;i
- 2015-01-23 23:26
- 浏览 410
- 分类:编程语言
- 博客分类：
- current
1、固定线程池：
package concurrent.threadpool;
import java.util.concurrent.executorservice;
import java.util.concurrent.executors;
/**
* 固定线程池
* 使用executors.newfixedthreadpool(3)方法指定池中允许执行线程的个数
* 如果超过这个线程个数,后面的线程就会等待
*/
public class fixedthreadpooltest {
public static void main(string[] ar ...
- 2015-01-23 23:21
- 浏览 1385
- 分类:编程语言