分类： 编程语言

package thread.map;

import java.util.concurrent.ConcurrentHashMap;

public class Consumer implements Runnable {

private String name;

private ConcurrentHashMap<String, String> map;

private int fromIndex;

public Consumer(String name, C

package thread.linkedqueue;

import java.util.concurrent.ConcurrentLinkedQueue;

import java.util.concurrent.CountDownLatch;

public class Worker implements Runnable {

private CountDownLatch downLatch;

private String name;

private Concurrent

package thread.schedule;

/**

* 实现Runnable接口

* @author add by jzh 2011-12-28

*

*/

public class Hello implements Runnable {

private String name;

public Hello(String name) {

this.name = name;

}

@Override

public void run() {

Sys

package thread.semaphore;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.Semaphore;

public class Test {

/**

* @author jzh 2011-12-27

* @param args

*/

public static voi

package thread.latch;

import java.util.concurrent.CountDownLatch;

public class Leader implements Runnable {

private CountDownLatch downLatch;

public Leader(CountDownLatch downLatch) {

this.downLatch = downLatch;

}

public void run() {

package thread.group;

public class SayThread extends Thread {

public SayThread(ThreadGroup group, String name) {

super(group, name);

}

public void run() {

for (int i = 0; i < 5; i++) {

System.out.println(getName() + ” = ” + i);

try

package thread.exchanger;

import java.util.concurrent.Exchanger;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

public class Test {

/**

* @author jzh 2011-12-27

* @param args

*/

public static voi

package thread.control;

public class ConsumerThread extends Thread {

private Warehouse warehouse;

private int number;

public ConsumerThread(Warehouse obj, int number) {

warehouse = obj;

this.number = number;

}

public void run() {

in

package thread.barrier;

import java.util.concurrent.ConcurrentHashMap;

public interface MasterDao {

public void count(ConcurrentHashMap<String, SaleReport> map);

}

package thread.barrier;

import java.util.Iterator;

import java.

package thread.readwrite;

import java.util.List;

public class Read implements Runnable {

private String name;

private RWLogic logic;

public Read(String name, RWLogic logic) {

this.name = name;

this.logic = logic;

}

public void run()

package thread.lock;

import java.util.concurrent.locks.Condition;

import java.util.concurrent.locks.Lock;

import java.util.concurrent.locks.ReentrantLock;

public class BoundedBuffer {

// 可重入锁

final Lock lock = new ReentrantLock();

// 两个

package thread.queue;

import java.text.SimpleDateFormat;

public class Consumer implements Runnable {

private String name;

private Warehouse queue;

public Consumer(String name, Warehouse warehouse) {

this.name = name;

this.queue = wareho

package thread.pool;

import java.util.concurrent.Callable;

/**

* Callable 和 Future接口

* Callable是类似于Runnable的接口，实现Callable接口的类和实现Runnable的类都是可被其它线程执行的任务。

* Callable和Runnable有几点不同：

* （1）Callable规定的方法是call()，而Runnable规定的方法是run().

* （2）Call

package thread.sync;

public class NumMake {

private int i = 0;

int getNext() {

return i++;

}

}

package thread.sync;

public class NumTest {

/**

* @author jzh 2011-12-19

* @param args

*/

public static void main(String[] args)

package thread;

/**

* 继承Thread类创建线程

* @author add by jzh 2011-12-17

*

*/

public class SayThread extends Thread {

public SayThread(String name) {

super(name);

}

public void run() {

for (int i = 0; i < 5; i++) {

System.out.pr

package thread;

/**

* 实现Runnable接口

* @author add by jzh 2011-12-17

*

*/

public class HelloThread implements Runnable {

private String name;

public HelloThread(String name) {

this.name = name;

}

@Override

public void run() {

sqlitejdbc-v056.jar。

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class Test {

/**

* @author jzh

* @remark sqlite jdbc 测试

* @

package thread.local;

import java.util.concurrent.atomic.AtomicInteger;

public class NumMake {

private static final AtomicInteger uniqueId = new AtomicInteger(0);

private static ThreadLocal<Integer> seqId = new ThreadLocal<Integer&gt

commons-codec-1.4.jar

commons-logging-1.1.1.jar

httpclient-4.1.2.jar

httpclient-cache-4.1.2.jar

httpcore-4.1.2.jar

httpmime-4.1.2.jar

import java.util.ArrayList;

import java.util.List;

import org.apache.http.HttpEntity;

import org.a