lzy/Linux-C-Notes
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🌈 style:

Browse Source
This commit is contained in:
lzy
2024-05-26 15:39:14 +08:00
parent 6f28a3384a
commit a57bbdb4c1
156 changed files with 765 additions and 770 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
C16-并发/parallel/signal/5sec.c
View File

@@ -9,7 +9,7 @@
* @param argv
* @return int
***********************************************************************/
int main(int argc, char **argv)
int main(int argc, char** argv)
{
time_t end;
long long count = 0;

2
C16-并发/parallel/signal/5sec_sig.c
View File

@@ -17,7 +17,7 @@ static void alrm_handler(int sig)
* @param argv
* @return int
***********************************************************************/
int main(int argc, char **argv)
int main(int argc, char** argv)
{
long long count = 0;

4
C16-并发/parallel/signal/alarm.c
View File

@@ -1,7 +1,7 @@
#include <stdlib.h>
#include <unistd.h>
int main(int argc, char **argv)
int main(int argc, char** argv)
{
alarm(10);
alarm(1);
@@ -14,7 +14,7 @@ int main(int argc, char **argv)
// 效果不一样
for (;;)
pause();
pause( );
exit(0);
}

4
C16-并发/parallel/signal/anytimer/anytimer.h
View File

@@ -2,7 +2,7 @@
#define __ANYTIMER__H__
#define JOB_MAX 1024
typedef void at_jobfunc_t(void *);
typedef void at_jobfunc_t(void*);
/********************************************************************
* @brief 创建定时器
@@ -16,7 +16,7 @@ typedef void at_jobfunc_t(void *);
* == -ENOMEM 失败，内存不足
* == -ENOSPC 失败，数组满
********************************************************************/
int at_addjob(int sec, at_jobfunc_t *jobp, void *arg);
int at_addjob(int sec, at_jobfunc_t* jobp, void* arg);
/********************************************************************
* @brief 取消定时器

10
C16-并发/parallel/signal/anytimer/main.c
View File

@@ -4,17 +4,17 @@
#include <string.h>
#include <unistd.h>
static void f1(void *p)
static void f1(void* p)
{
printf("f1():%s\n", (char *)p);
printf("f1():%s\n", (char*)p);
}
static void f2(void *p)
static void f2(void* p)
{
printf("f1():%s\n", (char *)p);
printf("f1():%s\n", (char*)p);
}
int main(int argc, char **argv)
int main(int argc, char** argv)
{
int job1;

2
C16-并发/parallel/signal/mycpy.c
View File

@@ -11,7 +11,7 @@
* time ./mycpy /etc/services /tmp/out
*/
int main(int argc, char **argv)
int main(int argc, char** argv)
{
int sfd, dfd;
char buf[BUFSIZE];

4
C16-并发/parallel/signal/mytbf/main.c
View File

@@ -14,13 +14,13 @@
#define BURST 100 //!! token上限
int main(int argc, char **argv)
int main(int argc, char** argv)
{
int sfd, dfd = 1;
char buf[BUFSIZE];
int len, ret, pos;
int size;
mytbf_t *tbf;
mytbf_t* tbf;
if (argc < 2)
{

30
C16-并发/parallel/signal/mytbf/mytbf.c
View File

@@ -25,12 +25,12 @@ struct mytbf_st
int pos;
};
static struct mytbf_st *job[MYTBF_MAX];
static struct mytbf_st* job[MYTBF_MAX];
static int inited = 0;
static __sighandler_t alrm_handler_save; //!!! 保存原来的alarm行为
static int get_free_pos()
static int get_free_pos( )
{
int i;
@@ -60,7 +60,7 @@ static void alrm_handler(int s)
}
}
static void module_unload()
static void module_unload( )
{
int i;
@@ -70,7 +70,7 @@ static void module_unload()
free(job[i]);
}
static void module_load()
static void module_load( )
{
alrm_handler_save = signal(SIGALRM, alrm_handler);
alarm(1);
@@ -78,18 +78,18 @@ static void module_load()
atexit(module_unload); //!!! atexit()
}
mytbf_t *mytbf_init(int cps, int burst)
mytbf_t* mytbf_init(int cps, int burst)
{
struct mytbf_st *me;
struct mytbf_st* me;
int pos;
if (!inited)
{
module_load();
module_load( );
inited = 1;
}
pos = get_free_pos();
pos = get_free_pos( );
if (pos < 0)
return NULL;
@@ -112,16 +112,16 @@ static int min(int a, int b)
return a < b ? a : b;
}
int mytbf_fetchtoken(mytbf_t *ptr, int size)
int mytbf_fetchtoken(mytbf_t* ptr, int size)
{
if (size <= 0)
return -EINVAL;
struct mytbf_st *me = ptr;
struct mytbf_st* me = ptr;
int n;
while (me->token <= 0)
pause();
pause( );
n = min(size, me->token);
@@ -130,12 +130,12 @@ int mytbf_fetchtoken(mytbf_t *ptr, int size)
return n;
}
int mytbf_returntoken(mytbf_t *ptr, int size)
int mytbf_returntoken(mytbf_t* ptr, int size)
{
if (size <= 0)
return -EINVAL;
struct mytbf_st *me = ptr;
struct mytbf_st* me = ptr;
me->token += size;
if (me->token > me->burst)
@@ -144,9 +144,9 @@ int mytbf_returntoken(mytbf_t *ptr, int size)
return size;
}
int mytbf_destroy(mytbf_t *ptr)
int mytbf_destroy(mytbf_t* ptr)
{
struct mytbf_st *me = ptr;
struct mytbf_st* me = ptr;
job[me->pos] = NULL;

8
C16-并发/parallel/signal/mytbf/mytbf.h
View File

@@ -15,12 +15,12 @@
#define MYTBF_MAX 1024
typedef void mytbf_t;
mytbf_t *mytbf_init(int cps, int burst);
mytbf_t* mytbf_init(int cps, int burst);
int mytbf_fetchtoken(mytbf_t *, int);
int mytbf_fetchtoken(mytbf_t*, int);
int mytbf_returntoken(mytbf_t *, int);
int mytbf_returntoken(mytbf_t*, int);
int mytbf_destroy(mytbf_t *);
int mytbf_destroy(mytbf_t*);
#endif //!__MYTBF__H__

4
C16-并发/parallel/signal/slowcat.c
View File

@@ -24,7 +24,7 @@ static void alrm_handler(int s)
* @param argv
* @return int
***********************************************************************/
int main(int argc, char **argv)
int main(int argc, char** argv)
{
int sfd, dfd = 1;
char buf[BUFSIZE];
@@ -67,7 +67,7 @@ int main(int argc, char **argv)
while (1)
{
while (!loop)
pause(); //!
pause( ); //!
loop = 0;
while ((len = read(sfd, buf, BUFSIZE)) < 0)

6
C16-并发/parallel/signal/slowcat2.c
View File

@@ -27,7 +27,7 @@ static void alrm_handler(int s)
* @param argv
* @return int
***********************************************************************/
int main(int argc, char **argv)
int main(int argc, char** argv)
{
int sfd, dfd = 1;
char buf[BUFSIZE];
@@ -59,9 +59,9 @@ int main(int argc, char **argv)
while (1)
{
while (token <= 0)
pause(); //!
pause( ); //!
token--; //!!! 这条指令不一定原子
token--; //!!! 这条指令不一定原子
//* 阻塞在这里的时候，token会自增
while ((len = read(sfd, buf, BUFSIZE)) < 0)

2
C16-并发/parallel/signal/star.c
View File

@@ -7,7 +7,7 @@ static void int_hander(int s)
write(1, "!", 1);
}
int main(int argc, char **argv)
int main(int argc, char** argv)
{
int i;