スレッドのプライオリティ(setpriority版)
をテンプレートにして作成
[
トップ
] [
新規
|
一覧
|
検索
|
最終更新
|
ヘルプ
|
ログイン
]
開始行:
* スレッドのプライオリティ(setpriority版) [#vfd46bf2]
前回の[[nice版>スレッドのプライオリティ(nice版)]]より、使...
glibc 2.2.4 以降では、 nice() は getpriority() を呼び出す...
懸念点があるとすれば、本来はプロセス単位で制御する点で、...
参考：[[Man page of GETPRIORITY:https://linuxjm.osdn.jp/h...
#highlight(c){{
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/syscall.h>
#include <pthread.h>
#include <sys/time.h>
#include <sys/resource.h>
#include <errno.h>
typedef struct {
pthread_t thread;
} thread_param_t;
/* スレッドID を取得する */
pid_t gettid(void)
{
/*
* glibc のラッパー関数が存在しないので間接システムコー...
*/
pid_t tid;
tid = syscall(SYS_gettid);
return tid;
}
/* プライオリティ表示 */
void disp_prio(int pid, int tid)
{
char head_msg[] = "head -n1 /proc/%d/sched";
char sched_msg[] = "cat /proc/%d/sched | grep -A 1 polic...
char msg[80] = {0};
/* メインプロセスのプライオリティ */
sprintf(msg, head_msg, pid);
system(msg);
sprintf(msg, sched_msg, pid);
system(msg);
/* スレッドのプライオリティ */
sprintf(msg, head_msg, tid);
system(msg);
sprintf(msg, sched_msg, tid);
system(msg);
}
/* スレッド */
void *thread_test(void *args)
{
int ret;
int pid, tid;
int policy;
int prio[3] = {19, -1, 0};
struct sched_param schedParam;
thread_param_t *thread_param = args;
int i;
pid = (int)getpid();
tid = (int)gettid();
printf("thread_test: pid = %d tid= %d\n", pid, tid);
disp_prio(pid, tid);
/* スレッドのスケージューリングパラメータを取得する */
ret = pthread_getschedparam(thread_param->thread, &polic...
if (ret != 0) {
fprintf(stderr, "pthread_getschedparam = %d\n", ret);
}
printf("policy = %d, sched_priority = %d\n", policy, sch...
for (i=0; i<3; i++) {
printf("change nice = %d\n", prio[i]);
/* スレッドプライオリティの変更 */
errno = 0;
ret = setpriority(PRIO_PROCESS, 0, prio[i]);
if (errno != 0) {
perror("setpriority");
}
disp_prio(pid, tid);
/* キー入力待ち */
getchar();
}
/* スレッドの終了 */
pthread_exit(NULL);
}
/* メイン */
int main(void)
{
int ret;
thread_param_t thread_param;
printf("my pid = %d\n", getpid());
/* 新しいスレッドを作成する */
ret = pthread_create(&thread_param.thread, NULL, thread_...
if (ret != 0) {
fprintf(stderr, "pthread_create = %d\n", ret);
}
/* 終了したスレッドを join する */
ret = pthread_join(thread_param.thread, NULL);
if (ret != 0) {
fprintf(stderr, "pthread_join = %d\n", ret);
}
return 0;
}
}}
#highlight(end)
#ref(thread_setpriority.tgz)
実行結果
$ ./thread_setpriority
my pid = 74433
thread_test: pid = 74433 tid= 74434
thread_setprior (74433, #threads: 2)
policy : ...
prio : ...
thread_setprior (74434, #threads: 2)
policy : ...
prio : ...
policy = 0, sched_priority = 0
change nice = 19
thread_setprior (74433, #threads: 2)
policy : ...
prio : ...
thread_setprior (74434, #threads: 2)
policy : ...
prio : ...
change nice = -1
setpriority: Permission denied
thread_setprior (74433, #threads: 2)
policy : ...
prio : ...
thread_setprior (74434, #threads: 2)
policy : ...
prio : ...
change nice = 0
setpriority: Permission denied
thread_setprior (74433, #threads: 2)
policy : ...
prio : ...
thread_setprior (74434, #threads: 2)
policy : ...
prio : ...
前回の[[nice版>スレッドのプライオリティ(nice版)]]同様にプ...
nice()と異なりデフォルトに対する相対値なので、プライオリ...
$ sudo ./thread_setpriority
my pid = 74476
thread_test: pid = 74476 tid= 74477
thread_setprior (74476, #threads: 2)
policy : ...
prio : ...
thread_setprior (74477, #threads: 2)
policy : ...
prio : ...
policy = 0, sched_priority = 0
change nice = 19
thread_setprior (74476, #threads: 2)
policy : ...
prio : ...
thread_setprior (74477, #threads: 2)
policy : ...
prio : ...
change nice = -1
thread_setprior (74476, #threads: 2)
policy : ...
prio : ...
thread_setprior (74477, #threads: 2)
policy : ...
prio : ...
change nice = 0
thread_setprior (74476, #threads: 2)
policy : ...
prio : ...
thread_setprior (74477, #threads: 2)
policy : ...
prio : ...
[[nice版>スレッドのプライオリティ(nice版)]]と異なり、デフ...
#htmlinsert(amazon_pc.html);
終了行:
* スレッドのプライオリティ(setpriority版) [#vfd46bf2]
前回の[[nice版>スレッドのプライオリティ(nice版)]]より、使...
glibc 2.2.4 以降では、 nice() は getpriority() を呼び出す...
懸念点があるとすれば、本来はプロセス単位で制御する点で、...
参考：[[Man page of GETPRIORITY:https://linuxjm.osdn.jp/h...
#highlight(c){{
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/syscall.h>
#include <pthread.h>
#include <sys/time.h>
#include <sys/resource.h>
#include <errno.h>
typedef struct {
pthread_t thread;
} thread_param_t;
/* スレッドID を取得する */
pid_t gettid(void)
{
/*
* glibc のラッパー関数が存在しないので間接システムコー...
*/
pid_t tid;
tid = syscall(SYS_gettid);
return tid;
}
/* プライオリティ表示 */
void disp_prio(int pid, int tid)
{
char head_msg[] = "head -n1 /proc/%d/sched";
char sched_msg[] = "cat /proc/%d/sched | grep -A 1 polic...
char msg[80] = {0};
/* メインプロセスのプライオリティ */
sprintf(msg, head_msg, pid);
system(msg);
sprintf(msg, sched_msg, pid);
system(msg);
/* スレッドのプライオリティ */
sprintf(msg, head_msg, tid);
system(msg);
sprintf(msg, sched_msg, tid);
system(msg);
}
/* スレッド */
void *thread_test(void *args)
{
int ret;
int pid, tid;
int policy;
int prio[3] = {19, -1, 0};
struct sched_param schedParam;
thread_param_t *thread_param = args;
int i;
pid = (int)getpid();
tid = (int)gettid();
printf("thread_test: pid = %d tid= %d\n", pid, tid);
disp_prio(pid, tid);
/* スレッドのスケージューリングパラメータを取得する */
ret = pthread_getschedparam(thread_param->thread, &polic...
if (ret != 0) {
fprintf(stderr, "pthread_getschedparam = %d\n", ret);
}
printf("policy = %d, sched_priority = %d\n", policy, sch...
for (i=0; i<3; i++) {
printf("change nice = %d\n", prio[i]);
/* スレッドプライオリティの変更 */
errno = 0;
ret = setpriority(PRIO_PROCESS, 0, prio[i]);
if (errno != 0) {
perror("setpriority");
}
disp_prio(pid, tid);
/* キー入力待ち */
getchar();
}
/* スレッドの終了 */
pthread_exit(NULL);
}
/* メイン */
int main(void)
{
int ret;
thread_param_t thread_param;
printf("my pid = %d\n", getpid());
/* 新しいスレッドを作成する */
ret = pthread_create(&thread_param.thread, NULL, thread_...
if (ret != 0) {
fprintf(stderr, "pthread_create = %d\n", ret);
}
/* 終了したスレッドを join する */
ret = pthread_join(thread_param.thread, NULL);
if (ret != 0) {
fprintf(stderr, "pthread_join = %d\n", ret);
}
return 0;
}
}}
#highlight(end)
#ref(thread_setpriority.tgz)
実行結果
$ ./thread_setpriority
my pid = 74433
thread_test: pid = 74433 tid= 74434
thread_setprior (74433, #threads: 2)
policy : ...
prio : ...
thread_setprior (74434, #threads: 2)
policy : ...
prio : ...
policy = 0, sched_priority = 0
change nice = 19
thread_setprior (74433, #threads: 2)
policy : ...
prio : ...
thread_setprior (74434, #threads: 2)
policy : ...
prio : ...
change nice = -1
setpriority: Permission denied
thread_setprior (74433, #threads: 2)
policy : ...
prio : ...
thread_setprior (74434, #threads: 2)
policy : ...
prio : ...
change nice = 0
setpriority: Permission denied
thread_setprior (74433, #threads: 2)
policy : ...
prio : ...
thread_setprior (74434, #threads: 2)
policy : ...
prio : ...
前回の[[nice版>スレッドのプライオリティ(nice版)]]同様にプ...
nice()と異なりデフォルトに対する相対値なので、プライオリ...
$ sudo ./thread_setpriority
my pid = 74476
thread_test: pid = 74476 tid= 74477
thread_setprior (74476, #threads: 2)
policy : ...
prio : ...
thread_setprior (74477, #threads: 2)
policy : ...
prio : ...
policy = 0, sched_priority = 0
change nice = 19
thread_setprior (74476, #threads: 2)
policy : ...
prio : ...
thread_setprior (74477, #threads: 2)
policy : ...
prio : ...
change nice = -1
thread_setprior (74476, #threads: 2)
policy : ...
prio : ...
thread_setprior (74477, #threads: 2)
policy : ...
prio : ...
change nice = 0
thread_setprior (74476, #threads: 2)
policy : ...
prio : ...
thread_setprior (74477, #threads: 2)
policy : ...
prio : ...
[[nice版>スレッドのプライオリティ(nice版)]]と異なり、デフ...
#htmlinsert(amazon_pc.html);
ページ名:
![[PukiWiki]](image/gbook_orange_80x80.png "[PukiWiki]")
