1 public static class Class1 2 { 3 static Queue MsgQueue = new Queue(); 4 5 static Class1() 6 { 7 ThreadPool.QueueUserWorkItem(q => 8 { 9 while (true.... ...
分类：
其他好文 时间：
2017-09-27 17:38:20
阅读次数：
156
日志服务需要提供的功能有：可以从外部安全地开启和关闭日志服务；可以供多个线程安全地记录日志消息；在日志服务关闭后，可以把剩余未记录的消息写入日志文件；public class LogService{ private final BlockingQueue msgQueue; /...
分类：
编程语言 时间：
2015-11-10 18:58:37
阅读次数：
242
/*
* handle.h
*/
#ifndef HANDLE_H_
#define HANDLE_H_
#include "msgqueue.h"
typedef struct HANDLER{
int send_sock;
char send_ip[128];
uint16 send_port;
int ind;
pthread_t th...
分类：
其他好文 时间：
2015-08-11 21:33:11
阅读次数：
153
/*
* mario_akg.h
*
业务逻辑注册
*
*/
#ifndef MARIO_AKG_H_
#define MARIO_AKG_H_
#include "mario_conn.h"
#include "mario_msgqueue.h"
#define MAX_PKG_TYPE (0xffff)
extern const ui...
分类：
其他好文 时间：
2015-08-11 21:33:01
阅读次数：
133
Client:#include #include #include #include #include #include #include #define MSG_SERVER "/msgqueue"#define BUF_LEN 20000int main(int argc,char** argv...
分类：
系统相关 时间：
2015-08-07 18:51:06
阅读次数：
204
linuxmsgget返回no spaceleft首先要说的是此类标准函数应该养成查看man手册了解其用法及返回值的习惯。返回nospaceleft分为两种情况：1，创建的msgqueue个数超过整个系统限制，通过ipcs-l查看系统对msgqueue限制的具体个数，通过ipcs-q查看当前已经创建...
分类：
系统相关 时间：
2014-11-13 00:24:44
阅读次数：
411
import timefrom multiprocessing import Process,QueueMSG_QUEUE = Queue(5)def startA(msgQueue): while True: if msgQueue.empty() > 0: ...
分类：
编程语言 时间：
2014-09-01 13:50:53
阅读次数：
227
