作者： 蒋智昊

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

iTextAsian.jar

itextpdf-5.1.3.jar

import java.io.FileOutputStream;

import com.itextpdf.text.Document;

import com.itextpdf.text.Font;

import com.itextpdf.text.Paragraph;

import com.itextpdf.text.pdf.BaseFont;

import com.itextpdf.text.pdf