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>
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