4

現在、 pthreads - githubを学習して実装したいと考えています。php7必要なコンポーネントでコンパイルし、thread-safety有効になっていることを確認しました。私の現在のコード例には、親クラスに属する 4 つの子クラスがありCanineます。以下に示すすべてのクラスから同時にThread実行するには、それに応じてクラスをどのように呼び出す必要がありますか? bark()クラスが 4 から 100 に成長したときのスケーリング機能を念頭に置いてください。プールですか。労働者？

 class Database {
    private $_host;
    private $_user;
    private $_pass;
    private $_dbname;
    private $_dsn;
    private $_options;
    public static $pdo;
    private $error;

    private $stmt;

    public function __construct() {
        $this->_host   = 'xxxxx';
        $this->_user   = 'xxxxx';
        $this->_pass   = 'xxxxx';
        $this->_dbname = 'xxxxx';
        $this->_dsn    = 'mysql:host=' . $this->_host . ';dbname=' . $this->_dbname;
        // Set options
        $this->_options = array(
            PDO::MYSQL_ATTR_LOCAL_INFILE => true,
            PDO::ATTR_PERSISTENT         => true,
            PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_TIMEOUT            => 1,
        );
    }

    public function __sleep() {
        return array('_dsn', '_user', '_pass');
    }

    public function __wakeup() {
        $this->connect();
    }

    public function connect() {
        try {
            return self::$pdo = new PDO($this->_dsn, $this->_user, $this->_pass, $this->_options);
        } catch (PDOException $e) {
            $this->error = $e->getMessage();
        }
    }
}

class DataAccessObject {
    protected $database;

    public function __construct() {
        //Create Instance of DB
        $this->database = (new Database())->connect();
    }

    public function insertQuery($query) {
        try {
            $select = $this->database->prepare($query);
            $select->execute();
            $results = $select->fetchAll(PDO::FETCH_ASSOC);
        } catch (Exception $e) {
            echo "Failed: " . $e->getMessage();
        }
        return true;
    }
}

class Helper extends DataAccessObject {
//code elided
}

abstract class Canine extends Helper {
    abstract public function bark();
}

//Child Classes

class GoldenRitriever extends Canine {
    public function bark() { echo 'arf-arf!<br>'; }
}

class Pitbull extends Canine {
    public function bark() { echo 'ruff-ruff!<br>'; }
}

class GermanShepherd extends Canine {
    public function bark() { echo 'wao-wao!<br>'; }
}

class LabradorRetriever extends Canine {
    public function bark() { echo 'woof-woof!<br>'; }
}

Creating instances and invoking `bark()`

$golden_ritriever = new GoldenRitriever();
$golden_ritriever->bark();

$pitbull = new Pitbull();
$pitbull->bark();

$german_shepherd = new GermanShepherd();
$german_shepherd->bark();

$labrador_retriever = new LabradorRetriever();
$labrador_retriever->bark();
4

1 に答える 1

4

あなたの問題はソリューションのアーキテクチャにあると思います。つまり、 Thread クラスをどこかに拡張する必要があり、どこにあるのかわかりません。

クラス構造 (ヘルパー、DataAccessObject) が最終的なものであり、DataAcessObject を Thread で拡張する意味がないと仮定すると、次のようにします。

class ThreadedCanine extends Thread {
    private $canine;
    public function __construct(Canine $canine) {
        $this->canine = $canine;
    }

    public function run() {
        $this->canine->bark();
    }
}

$threads = [
    new ThreadedCanine(new GoldenRitriever()),
    new ThreadedCanine(new Pitbull()),
    new ThreadedCanine(new GermanShepherd()),
    new ThreadedCanine(new LabradorRetriever()),
];

foreach($threads as $thread) {
    $thread->start();
}

foreach($threads as $thread) {
    $thread->join();
}

これは良い方法だと思います。なぜなら、常にスレッドである必要はないので、犬を強制的にスレッドにする必要がないからです。

編集

元の回答で、何百ものスレッドにスケーリングしたい場合は、はい、それを管理するためにPoolandWorkerクラスを使用する必要があることを忘れていました (ドキュメントでは、スレッドの代わりにワーカーを使用することも推奨されています)。そうでない場合は、100 を起動しますスレッドを同時に行うのは良くありません (複数のクライアントがある場合はさらに悪化します) :P

スレッドの使い方をよく理解したら、それらのシナリオに進むことができます。

それが役に立てば幸い ：）

于 2016-09-07T15:56:06.667 に答える