线程池实现
/* -------------------------------------------------------------------------
* log.h
* -------------------------------------------------------------------------
*/
#ifndef __LOG_H
#define __LOG_H
#include
by jyh20031984 - C/C++ - 2009-12-16 17:20:04 阅读（11478） 回复（21）
实现代码： #coding:utf-8 import Queue import threading import sys import time import urllib #替我们工作的线程池中的线程 class MyThread(threading.Thread): def __init__(self, workQueue, resultQueue,timeout=30, **kwargs): threading.Thread.__init__(self, kwargs=kwargs) #线程在结束前等待任务队列多长时间 self.timeout = timeout self.setDaemon(True) self.workQueue = workQueue self.resultQueu...
这只是一个线程池的框架还有许多不足 : 没有实现server->client数据发送 , 还有许多细节没有完善。 Lock.cpp : 锁的操作 , 读锁可以并发 , 写锁独占. Queue.h : 队列的封装 , 队列的读和写都加了锁的保护. Socket.cpp : 套接口的简单封装. Thread.cpp : 线程的封装实现了些简单的线程停止，运行等功能 , 启动别的线程的时候需要继承次类. Worker.cpp : 用户接口类 , 用户需继承此类。 ListenThread.cpp(继承Threa...
我想在程序中一开始就创建了N个空闲线程，后面有任务时就将任务分配给空闲的进程让他执行。 1。pthread_create是不是一创建就开始运行？如何使得成为空闲线程？ 2。任务来时，我如何让空闲的线程运行，运行完毕后又回到空闲状态？
要点：在服务端架构一个Socket线程池，每一个客户端连接到Server端，Server从线程池中调用一个空闲的线程处理一个client socket. 1.Server.java package com.test.socket; import java.io.BufferedInputStream; import java.io.DataInputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; import com.test.threadpoolsocket.SocketThreadPool; public class Server { public sta...
由二部分组成，一个线程管理类ThreadManager，一个线程类MyThread Test类是用来测试的 参考了以下资料： http://tech.ccidnet.com/pub/disp/Article?columnID=294&articleID=33440&pageNO=1 http://soft.yesky.com/SoftChannel/72342371961929728/20041013/1863707.shtml 下面是代码，希望大家提出更好的建议： 1.ThreadManager.cs using System; using System.Threading; using System.Collections; namespace CustomTh...
Java版线程池实现 线程池调度技术原理： package test.threadpool; import java.util.*; import test.cfg.*; public class ThreadPool { private int reserve = 0; //保留线程 private int minPools = 10; //最小连接池数目，预启动线程数目 private int maxActive = 70; //最多活动线程数目 private int maxPools = 100; //最大连接池数目 private int checkThreadPeriod = 5; //检查连接池的周期 ArrayList m_ThreadLis...
