getOrSet2.php · 阿宝/threadtask

Fetch the repository succeeded.

Open Source > Development Lib > Common Toolkit &&

richgiteeai

Watch

Unwatch Watching Releases Only Ignoring

3 Star 21 Fork 3

阿宝/threadtask

Code Issues 0 Pull Requests 0 Insights Pipelines

Service

Tencent Cloud Serverless

Create your Gitee Account

Explore and code with more than 14 million developers,Free private repositories !:)

Already have an account? Sign in

文件

main

Branches (1)

Tags (76)

Manage

main

v1.75

v1.74

v1.73

v1.72

v1.71

v1.70

v1.69

v1.68

v1.67

v1.66

v1.65

v1.64

v1.63

v1.62

v1.61

v1.60

v1.59

v1.58

v1.57

v1.56

Clone or Download

Clone/Download

HTTPS SSH SVN SVN+SSH Download ZIP

Prompt

To download the code, please copy the following command and execute it in the terminal

To ensure that your submitted code identity is correctly recognized by Gitee, please execute the following command.

git config --global user.name userName 
git config --global user.email userEmail

When using the SSH protocol for the first time to clone or push code, follow the prompts below to complete the SSH configuration.

1 Generate RSA keys.

2 Obtain the content of the RSA public key and configure it in SSH Public Keys

To use SVN on Gitee, please visit the usage guide

When using the HTTPS protocol, the command line will prompt for account and password verification as follows. For security reasons, Gitee recommends configure and use personal access tokens instead of login passwords for cloning, pushing, and other operations.

Username for 'https://gitee.com': userName

Password for 'https://userName@gitee.com': # Private Token

Branches 1

Tags 76

threadtask

getOrSet2.php

getOrSet2.php 1.08 KB

<?php
pthread_sigmask(SIG_SETMASK, []);
	
$running = true;

pcntl_async_signals(true);
pcntl_signal(SIGINT, function() use(&$running) {
	printf("SIGINT\n");
	$running = false;
}, false);

$var1 = ts_var_declare(1);
$var2 = ts_var_declare(2);

register_shutdown_function(function() {
	printf("EXIT: %s\n", THREAD_TASK_NAME);
});

if(!is_main_task()) {
	$i = 0;
	if(THREAD_TASK_NAME == 'task0') {
		while($running) {
			ts_var_get_or_set($var1, ++$i, function() use($var2, &$i) {
				ts_var_get_or_set($var2, $i, function() {
					usleep(5000); // 5ms
					return 1;
				});
			});
			if($i >= 100) $i = 0;
		}
	} else {
		while($running) {
			ts_var_get_or_set($var1, ++$i, function() use($var2, &$i) {
				ts_var_get_or_set($var2, $i, function() {
					usleep(5000); // 5ms
					return 1;
				});
			});
			if($i >= 100) $i = 0;
		}
	}
} else {
	create_task('task0', __FILE__, [], null, null, $waits[0]);
	create_task('task1', __FILE__, [], null, null, $waits[1]);
	
	$var = ts_var_declare(null);
	
	while($running && ($n = task_get_threads()) > 0) {
		sleep(1);
		echo "$n\n";
	}
	
	task_wait(SIGINT);
}

Copy Edit Raw Blame History

阿宝 authored 2022年04月29日 01:51 +08:00 . 主线程添加THREAD_TASK_NAME常量且值为main,添加is_main_task函数且别名为is_main_thread。

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55

<?php
pthread_sigmask(SIG_SETMASK, []);
	
$running = true;

pcntl_async_signals(true);
pcntl_signal(SIGINT, function() use(&$running) {
	printf("SIGINT\n");
	$running = false;
}, false);

$var1 = ts_var_declare(1);
$var2 = ts_var_declare(2);

register_shutdown_function(function() {
	printf("EXIT: %s\n", THREAD_TASK_NAME);
});

if(!is_main_task()) {
	$i = 0;
	if(THREAD_TASK_NAME == 'task0') {
		while($running) {
			ts_var_get_or_set($var1, ++$i, function() use($var2, &$i) {
				ts_var_get_or_set($var2, $i, function() {
					usleep(5000); // 5ms
					return 1;
				});
			});
			if($i >= 100) $i = 0;
		}
	} else {
		while($running) {
			ts_var_get_or_set($var1, ++$i, function() use($var2, &$i) {
				ts_var_get_or_set($var2, $i, function() {
					usleep(5000); // 5ms
					return 1;
				});
			});
			if($i >= 100) $i = 0;
		}
	}
} else {
	create_task('task0', __FILE__, [], null, null, $waits[0]);
	create_task('task1', __FILE__, [], null, null, $waits[1]);
	
	$var = ts_var_declare(null);
	
	while($running && ($n = task_get_threads()) > 0) {
		sleep(1);
		echo "$n\n";
	}
	
	task_wait(SIGINT);
}

误判申诉

此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。

如您确认内容无涉及不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。

取消

提交

About

php多线程任务,优点是占用内存少且稳定,对于并行任务处理也有另活的应用。

No labels

21 Stars

3 Watching

3 Forks

Cancel

Releases (22)

All

v1.75

The Open Source Evaluation Index is derived from the OSS Compass evaluation system, which evaluates projects around the following three dimensions

1. Open source ecosystem

Productivity: To evaluate the ability of open-source projects to output software artifacts and open-source value.
Innovation: Used to evaluate the degree of diversity of open source software and its ecosystem.
Robustness: Used to evaluate the ability of open-source projects to resist internal and external interference and self recover in the face of changing development environments.

2. Collaboration, People, Software

Collaboration: represents the degree and depth of collaboration in open source development behavior.
Observe the influence of core personnel in open source projects, and examine the evaluations of users and developers on open source projects from a third-party perspective.
Software: Evaluate the value of products exported from open-source projects and their ultimate destination. It is also a concrete manifestation of "open source software", one of the oldest mainstream directions in open source evaluation.

3. Evaluation model

Based on the dimensions of "open source ecosystem" and "collaboration, people, and software", identify quantifiable indicators directly or indirectly related to this goal, quantitatively evaluate the health and ecology of open source projects, and ultimately form an open source evaluation index.